1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283
import { assertEquals } from "https://deno.land/x/testing/asserts.ts";import { runTests, test } from "https://deno.land/x/testing/mod.ts";import { Client } from "./mod.ts";import "./tests/query.ts";
let client: Client;
test(async function testCreateDb() {  await client.query(`CREATE DATABASE IF NOT EXISTS enok`);  await client.query(`USE enok`);});
test(async function testCreateTable() {  await client.query(`DROP TABLE IF EXISTS users`);  await client.query(`        CREATE TABLE users (            id int(11) NOT NULL AUTO_INCREMENT,            name varchar(100) NOT NULL,            created_at timestamp not null default current_timestamp,            PRIMARY KEY (id)        ) ENGINE=InnoDB DEFAULT CHARSET=utf8;    `);});
test(async function testInsert() {  let result = await client.execute(`INSERT INTO users(name) values(?)`, [    "manyuanrong"  ]);  assertEquals(result, { affectedRows: 1, lastInsertId: 1 });  result = await client.execute(`INSERT INTO users ?? values ?`, [    ["id", "name"],    [2, "MySQL"]  ]);  assertEquals(result, { affectedRows: 1, lastInsertId: 2 });});
test(async function testUpdate() {  let result = await client.execute(`update users set ?? = ? WHERE id = ?`, [    "name",    "MYR",    1  ]);  assertEquals(result, { affectedRows: 1, lastInsertId: 0 });});
test(async function testQuery() {  let result = await client.query("select ??,name from ?? where id = ?", [    "id",    "users",    1  ]);  assertEquals(result, [{ id: 1, name: "MYR" }]);});
test(async function testDelete() {  let result = await client.execute(`delete from users where ?? = ?`, [    "id",    1  ]);  assertEquals(result, { affectedRows: 1, lastInsertId: 0 });});
async function main() {  const { DB_PORT, DB_NAME, DB_PASSWORD, DB_USER, DB_HOST } = Deno.env();  const port = DB_PORT ? parseInt(DB_PORT) : 3306;  const db = DB_NAME;  const password = DB_PASSWORD;  const username = DB_USER || "root";  const hostname = DB_HOST || "127.0.0.1";  client = await new Client().connect({    timeout: 10000,    debug: true,    hostname,    username,    port,    db,    password  });  runTests();}
main();