Function getTableSchema

src/lib/connectors/mysql/index.ts:87–112

(connection: Connection, databaseName: string)

};

const getTableSchema = async (connection: Connection, databaseName: string): Promise<Schema[]> => {
  const conn = await getMySQLConnection(connection);
  // get All tableList from database
  const [rows] = await conn.query<RowDataPacket[]>(
    // SYSTEM VERSIONED is a special table for MariaDB https://mariadb.com/kb/en/system-versioned-tables/
    `SELECT TABLE_NAME as table_name FROM information_schema.tables WHERE TABLE_SCHEMA=? AND (TABLE_TYPE='BASE TABLE' || TABLE_TYPE='SYSTEM VERSIONED');`,
    [databaseName]
  );
  const tableList = [];
  for (const row of rows) {
    if (row["table_name"]) {
      tableList.push(row["table_name"]);
    }
  }
  const SchemaList: Schema[] = [{ name: "", tables: [] as Table[] }];

  for (const tableName of tableList) {
    const [rows] = await conn.query<RowDataPacket[]>(`SHOW CREATE TABLE \`${databaseName}\`.\`${tableName}\`;`);
    if (rows.length !== 1) {
      throw new Error("Unexpected number of rows.");
    }

    SchemaList[0].tables.push({ name: tableName, structure: rows[0]["Create Table"] || "" });
  }
  return SchemaList;
};

const newConnector = (connection: Connection): Connector => {
  return {