UNPKG

rslib

Version:

## Create mysql pool ```js const mysql = require('rslib').mysql;

93 lines (78 loc) 1.59 kB
# Basic usages ## Create mysql pool ```js 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])` ```js let res = await db.query('SELECT * FROM `users` WHERE `role` = ?', ['admin']); console.log(res); ``` ## Insert `insert(table, data, { ignore = false })` ```js 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 })` ```js let updated = await db.update('users', 123, { name: 'John Doe', active: true }); console.log(updated); // updated ``` or ```js 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' })` ```js let user = await db.get('users', 123); console.log(user); // user with id=123 ``` or ```js 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' })` ```js let affected = await db.delete('users', 123); console.log(affected); // affected rows ``` ## Transactions ```js let tr = await db.begin(); await tr.query('...'); await tr.query('...'); tr.commit(); // or tr.rollback(); ```