npm install @deepagents/text2sql
npm install mysql2

import { Mysql, tables, views, info } from '@deepagents/text2sql/mysql';
import mysql from 'mysql2/promise';

const pool = mysql.createPool({
  host: 'localhost',
  database: 'mydb',
  user: 'root',
  password: 'password'
});

const adapter = new Mysql({
  execute: async (sql) => {
    const [rows] = await pool.execute(sql);
    return rows;
  },
  grounding: [tables(), views(), info()],
  databases: ['mydb']  // Optional: limit to specific databases
});

import { Mariadb, tables } from '@deepagents/text2sql/mysql';

const adapter = new Mariadb({
  execute: async (sql) => {
    const [rows] = await pool.execute(sql);
    return rows;
  },
  grounding: [tables()]
});

interface MysqlAdapterOptions {
  execute: ExecuteFunction;
  validate?: ValidateFunction;
  grounding: GroundingFn[];
  databases?: string[];  // Limit to specific databases
}

adapter.quoteIdentifier('my_table');  // `my_table`
adapter.quoteIdentifier('my column'); // `my column`

SELECT * FROM customers LIMIT 10

import { Text2Sql } from '@deepagents/text2sql';
import { Mysql, tables, constraints } from '@deepagents/text2sql/mysql';
import { InMemoryContextStore } from '@deepagents/context';
import { openai } from '@ai-sdk/openai';
import mysql from 'mysql2/promise';

const pool = mysql.createPool({
  host: 'localhost',
  database: 'ecommerce',
  user: 'root',
  password: 'password',
  waitForConnections: true,
  connectionLimit: 10,
  queueLimit: 0
});

const adapter = new Mysql({
  execute: async (sql) => {
    const [rows] = await pool.execute(sql);
    return rows;
  },
  grounding: [tables(), constraints()]
});

const text2sql = new Text2Sql({
  version: 'v1',
  model: openai('gpt-4o'),
  adapter,
  store: new InMemoryContextStore()
});

const sql = await text2sql.toSql('Show top 10 customers by revenue');
console.log(sql);

const pool = mysql.createPool({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'mydb',
  connectionLimit: 10
});

CREATE INDEX idx_customers_email ON customers(email);
CREATE UNIQUE INDEX idx_users_username ON users(username);

-- Use EXPLAIN to analyze
EXPLAIN SELECT * FROM customers WHERE email = '[email protected]';