rslib
Version:
## Create mysql pool ```js const mysql = require('rslib').mysql;
93 lines (78 loc) • 1.59 kB
Plain Text
```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(sql[, values])`
```js
let res = await db.query('SELECT * FROM `users` WHERE `role` = ?', ['admin']);
console.log(res);
```
`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(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(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(table, id, { pk = 'id' })`
```js
let affected = await db.delete('users', 123);
console.log(affected); // affected rows
```
```js
let tr = await db.begin();
await tr.query('...');
await tr.query('...');
tr.commit();
// or tr.rollback();
```