Function execute

src/lib/connectors/mysql/index.ts:53–69

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

};

const execute = async (connection: Connection, databaseName: string, statement: string): Promise<any> => {
  connection.database = databaseName;
  const conn = await getMySQLConnection(connection);
  const [rows] = await conn.execute(statement);
  conn.destroy();

  const executionResult: ExecutionResult = {
    rawResult: [],
    affectedRows: 0,
  };
  if (Array.isArray(rows)) {
    executionResult.rawResult = rows;
  } else {
    executionResult.affectedRows = rows.affectedRows;
  }
  return executionResult;
};

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