npm install @deepagents/text2sql
npm install mssql

import { SqlServer, tables, views, info, indexes } from '@deepagents/text2sql/sqlserver';
import sql from 'mssql';

const pool = new sql.ConnectionPool({
  server: 'localhost',
  database: 'mydb',
  user: 'sa',
  password: 'password'
});
await pool.connect();

const adapter = new SqlServer({
  execute: async (query) => {
    const result = await pool.request().query(query);
    return result.recordset;
  },
  grounding: [tables(), views(), info(), indexes()],
  schemas: ['dbo', 'staging']  // Optional
});

interface SqlServerAdapterOptions {
  execute: ExecuteFunction;
  validate?: ValidateFunction;
  grounding: GroundingFn[];
  schemas?: string[];  // Default: excludes 'INFORMATION_SCHEMA', 'sys'
}

adapter.quoteIdentifier('my_table');  // [my_table]
adapter.quoteIdentifier('my column'); // [my column]

-- SQL Server syntax
SELECT TOP 10 * FROM customers

-- Not: SELECT * FROM customers LIMIT 10

const adapter = new SqlServer({
  execute: async (sql) => {
    const result = await pool.request().query(sql);
    return result.recordset;
  },
  validate: async (sql) => {
    // Custom validation
    await pool.request().query(`SET PARSEONLY ON; ${sql}; SET PARSEONLY OFF;`);
  },
  grounding: [tables()]
});

import { Text2Sql } from '@deepagents/text2sql';
import { SqlServer, tables, constraints } from '@deepagents/text2sql/sqlserver';
import { InMemoryContextStore } from '@deepagents/context';
import { openai } from '@ai-sdk/openai';
import sql from 'mssql';

const pool = new sql.ConnectionPool({
  server: 'localhost',
  database: 'ecommerce',
  user: 'sa',
  password: 'YourStrong@Password',
  options: {
    encrypt: true,
    trustServerCertificate: true
  }
});

await pool.connect();

const adapter = new SqlServer({
  execute: async (query) => {
    const result = await pool.request().query(query);
    return result.recordset;
  },
  grounding: [tables(), constraints()],
  schemas: ['dbo']
});

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);
// SELECT TOP 10 * FROM [dbo].[customers] ORDER BY [total_revenue] DESC

CREATE SCHEMA staging;
CREATE SCHEMA analytics;

CREATE TABLE staging.import_data (...);
CREATE TABLE analytics.daily_metrics (...);

const pool = new sql.ConnectionPool({
  // ...
  pool: {
    max: 20,
    min: 0,
    idleTimeoutMillis: 30000
  }
});

CREATE NONCLUSTERED INDEX IX_Customers_Email 
  ON dbo.Customers(Email);

CREATE CLUSTERED INDEX IX_Orders_CreatedAt 
  ON dbo.Orders(CreatedAt);