API

connect

import{Client}from"https://deno.land/x/mysql/mod.ts";constclient=awaitnewClient().connect({hostname:"127.0.0.1",username:"root",db:"dbname",password:"password",});

connect pool

import{Client}from"https://deno.land/x/mysql/mod.ts";constclient=awaitnewClient().connect({hostname:"127.0.0.1",username:"root",db:"dbname",poolSize:3,// connection limitpassword:"password",});

create database

awaitclient.execute(`CREATE DATABASE IF NOT EXISTS enok`);awaitclient.execute(`USE enok`);

create table

awaitclient.execute(`DROP TABLE IF EXISTS users`);awaitclient.execute(`    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;`);

insert

letresult=awaitclient.execute(`INSERT INTO users(name) values(?)`,["manyuanrong",]);console.log(result);// { affectedRows: 1, lastInsertId: 1 }

update

letresult=awaitclient.execute(`update users set ?? = ?`,["name","MYR"]);console.log(result);// { affectedRows: 1, lastInsertId: 0 }

delete

letresult=awaitclient.execute(`delete from users where ?? = ?`,["id",1]);console.log(result);// { affectedRows: 1, lastInsertId: 0 }

query

constusername="manyuanrong";constusers=awaitclient.query(`select * from users`);constqueryWithParams=awaitclient.query("select ??,name from ?? where id = ?",["id","users",1],);console.log(users,queryWithParams);

execute

const{rows:users}=awaitclient.execute(`select * from users`);console.log(users);

awaitclient.useConnection(async(conn)=>{// note the third parameter of execute() method.const{iterator:users}=awaitconn.execute(`select * from users`,/* params: */[],/* iterator: */true,);forawait(constuserofusers){console.log(user);}});

transaction

constusers=awaitclient.transaction(async(conn)=>{awaitconn.execute(`insert into users(name) values(?)`,["test"]);returnawaitconn.query(`select ?? from ??`,["name","users"]);});console.log(users.length);

close

awaitclient.close();

Logging

import{configLogger}from"https://deno.land/x/mysql/mod.ts";awaitconfigLogger({enable:false});

Test

docker container run --rm -d -p 3306:3306 -e MYSQL_ALLOW_EMPTY_PASSWORD=true docker.io/mariadb:latestdenotest --allow-env --allow-net=127.0.0.1:3306 ./test.ts