Basic usages

Create mysql pool

const mysql = require('rslib').mysql;

async function app() {

    let db = await mysql.getInstance({
        host: 'localhost',
        user: 'root',
        password: '',
        database: 'test',
        connectionLimit: 10,
        verbose: 2
    });

    // do other things...

}

app();

Query

query(sql[, values])

let res = await db.query('SELECT * FROM `users` WHERE `role` = ?', ['admin']);
console.log(res);

Insert

insert(table, data, { ignore = false })

let id = await db.insert('users', {
    username: 'admin',
    password: 'superpasswordhash',
    name: 'John Doe'
});
console.log(id); // inserted id

Update

update(table, id, data, { pk = 'id', ignore = false })

let updated = await db.update('users', 123, {
    name: 'John Doe',
    active: true
});
console.log(updated); // updated

or

let updated = await db.update('users', 'admin', {
    name: 'John Doe',
    active: true
}, { pk: 'username' });
console.log(updated); // updated

Get

get(table, id, { fields = ['*'], pk = 'id' })

let user = await db.get('users', 123);
console.log(user); // user with id=123

or

let user = await db.get('users', 'admin', {
    pk: 'username',
    fields: ['id','email','name']
});
console.log(user); // get id,email,name of user with username=admin

Delete

delete(table, id, { pk = 'id' })

let affected = await db.delete('users', 123);
console.log(affected); // affected rows

Transactions

let tr = await db.begin();

await tr.query('...');
await tr.query('...');

tr.commit();
// or tr.rollback();