rslib v0.0.10

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();