Function initGenerateDataClientSide

src/bin/pgbench/pgbench.c:4170–4300

* Fill the standard tables with some data generated and sent from the client */

 * Fill the standard tables with some data generated and sent from the client
 */
static void
initGenerateDataClientSide(PGconn *con)
{
	PQExpBufferData sql;
	PGresult   *res;
	int			i;
	int64		k;

	/* used to track elapsed time and estimate of the remaining time */
	pg_time_usec_t start;
	int			log_interval = 1;

	/* Stay on the same line if reporting to a terminal */
	char		eol = isatty(fileno(stderr)) ? '\r' : '\n';

	fprintf(stderr, "generating data (client-side)...\n");

	/*
	 * we do all of this in one transaction to enable the backend's
	 * data-loading optimizations
	 */
	executeStatement(con, "begin");

	/* truncate away any old data */
	initTruncateTables(con);

	initPQExpBuffer(&sql);

	/*
	 * fill branches, tellers, accounts in that order in case foreign keys
	 * already exist
	 */
	for (i = 0; i < nbranches * scale; i++)
	{
		/* "filler" column defaults to NULL */
		printfPQExpBuffer(&sql,
						  "insert into pgbench_branches(bid,bbalance) values(%d,0)",
						  i + 1);
		executeStatement(con, sql.data);
	}

	for (i = 0; i < ntellers * scale; i++)
	{
		/* "filler" column defaults to NULL */
		printfPQExpBuffer(&sql,
						  "insert into pgbench_tellers(tid,bid,tbalance) values (%d,%d,0)",
						  i + 1, i / ntellers + 1);
		executeStatement(con, sql.data);
	}

	/*
	 * accounts is big enough to be worth using COPY and tracking runtime
	 */
	res = PQexec(con, "copy pgbench_accounts from stdin");
	if (PQresultStatus(res) != PGRES_COPY_IN)
	{
		pg_log_fatal("unexpected copy in result: %s", PQerrorMessage(con));
		exit(1);