Function execute

src/lib/connectors/postgres/index.ts:59–74

(connection: Connection, databaseName: string, statement: string)

};

const execute = async (connection: Connection, databaseName: string, statement: string): Promise<any> => {
  connection.database = databaseName;
  const client = await newPostgresClient(connection);
  const { rows, rowCount } = await client.query(statement);
  await client.end();

  const executionResult: ExecutionResult = {
    rawResult: rows,
    affectedRows: rowCount,
  };
  // For those SELECT statement, we should set the affectedRows to undefined.
  if (executionResult.rawResult.length === rowCount) {
    executionResult.affectedRows = undefined;
  }
  return executionResult;
};

const getDatabases = async (connection: Connection): Promise<string[]> => {
  const client = await newPostgresClient(connection);