import { describe, it, expect, beforeAll, afterAll } from "vitest";
import { MySQLAdapter } from "../MySQLAdapter.js";
describe("MySQLAdapter Integration", () => {
let adapter: MySQLAdapter;
// Credentials from docker-compose.yml
const config = {
type: "mysql" as const,
host: "localhost", // Or host.docker.internal if running inside docker, but vitest runs on host
port: 3306,
username: "root",
password: "root",
database: "testdb",
};
beforeAll(async () => {
adapter = new MySQLAdapter();
try {
await adapter.connect(config);
console.log("Connected to MySQL Docker container");
} catch (error) {
console.warn(
"Skipping integration tests: Could not connect to MySQL Docker container",
error,
);
// Skip suite if connection fails (e.g. docker not running)
return;
}
});
afterAll(async () => {
if (adapter && adapter.isConnected()) {
await adapter.executeWriteQuery("DROP TABLE IF EXISTS integration_test");
await adapter.disconnect();
}
});
it("should create a test table", async () => {
if (!adapter.isConnected()) return;
await adapter.executeWriteQuery(`
CREATE TABLE IF NOT EXISTS integration_test (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(255) NOT NULL,
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
)
`);
// Verify table exists
const tables = await adapter.listTables();
const found = tables.some((t) => t.name === "integration_test");
expect(found).toBe(true);
});
it("should insert and retrieve data", async () => {
if (!adapter.isConnected()) return;
// Insert
const insertResult = await adapter.executeWriteQuery(
"INSERT INTO integration_test (name) VALUES (?)",
["test_item"],
);
expect(insertResult.rowsAffected).toBe(1);
// Retrieve
const selectResult = await adapter.executeReadQuery(
"SELECT * FROM integration_test WHERE name = ?",
["test_item"],
);
expect(selectResult.rows).toBeDefined();
expect(selectResult.rows).toHaveLength(1);
expect((selectResult.rows![0] as any).name).toBe("test_item");
});
it("should handle transactions correctly", async () => {
if (!adapter.isConnected()) return;
// 1. Begin Transaction
const txId = await adapter.beginTransaction();
expect(txId).toBeDefined();
// 2. Insert data within transaction
await adapter.executeWriteQuery(
"INSERT INTO integration_test (name) VALUES (?)",
["rollup_item"],
txId, // Passed txId
);
// 3. Rollback
await adapter.rollbackTransaction(txId);
// 4. Verify data was NOT committed
const result = await adapter.executeReadQuery(
"SELECT * FROM integration_test WHERE name = ?",
["rollup_item"],
);
expect(result.rows).toHaveLength(0);
});
it("should commit transactions correctly", async () => {
if (!adapter.isConnected()) return;
// 1. Begin Transaction
const txId = await adapter.beginTransaction();
// 2. Insert data
await adapter.executeWriteQuery(
"INSERT INTO integration_test (name) VALUES (?)",
["commit_item"],
txId, // Passed txId
);
// 3. Commit
await adapter.commitTransaction(txId);
// 4. Verify data WAS committed
const result = await adapter.executeReadQuery(
"SELECT * FROM integration_test WHERE name = ?",
["commit_item"],
);
expect(result.rows).toHaveLength(1);
});
it("should describe table metadata accurately", async () => {
if (!adapter.isConnected()) return;
const tableInfo = await adapter.describeTable("integration_test");
expect(tableInfo.name).toBe("integration_test");
expect(tableInfo.columns).toBeDefined();
const nameCol = tableInfo.columns?.find((c) => c.name === "name");
expect(nameCol).toBeDefined();
expect(nameCol?.type).toContain("varchar");
});
it("should execute raw queries", async () => {
if (!adapter.isConnected()) return;
const result = await adapter.rawQuery('SHOW VARIABLES LIKE "version"');
expect(result.rows).toBeDefined();
expect(result.rows!.length).toBeGreaterThan(0);
});
it("should support transaction isolation levels", async () => {
if (!adapter.isConnected()) return;
const txId = await adapter.beginTransaction("READ COMMITTED");
expect(txId).toBeDefined();
await adapter.commitTransaction(txId);
});
it("should get full schema info", async () => {
if (!adapter.isConnected()) return;
const schema = await adapter.getSchema();
expect(schema.tables).toBeDefined();
expect(schema.tables.some((t) => t.name === "integration_test")).toBe(true);
});
});
