node.js使用mysql模块,连接并处理mysql数据库

一、使用 createConnection 获取连接:   

const mysql = require('mysql');
const conn = mysql.createConnection({
host: 'localhost',
port: 3306,
user: 'test',
password: '1',
database: 'study'
});

/** 查询数据 */
conn.query('select * from banji', function (err, rows, fields) {
if (err) {
console.
log(err);
} else {
console.
log(`查询出 ${rows.length} 条数据,第一条数据为 ${JSON.stringify(rows[0])}`);
}
})
;

/** 添加数据 */
let banjiData = [4, '特长班'];
conn.query("INSERT INTO banji(banji_id,name) VALUES(?,?)", banjiData, function (err, results) {
if (err) {
console.
log(err);
} else {
console.
log(results);
}
})
;

/** 删除数据 */
conn.query("DELETE FROM banji WHERE banji_id=?", [4], function (err, results) {
if (err) {
console.
log(err);
} else {
console.
log(results);
}
})
;

/** 修改数据 */
conn.query("UPDATE banji SET name=? WHERE banji_id=?", ['特长贪睡班', 4], function (err, results) {
if (err) {
console.
log(err);
} else {
console.
log(results);
}
})
;

conn.end();

二、使用 createPool 创建连接池:   

const mysql = require('mysql');
const pool = mysql.createPool({
host: 'localhost',
port: 3306,
user: 'test',
password: '1',
database: 'study'
});

pool.getConnection((err, conn) => {
/** 查询数据 */
conn.query('select * from banji', function (err, rows, fields) {
if (err) {
console.
log(err);
} else {
console.
log(`查询出 ${rows.length} 条数据,第一条数据为 ${JSON.stringify(rows[0])}`);
}
})
;
conn.release();//用完连接后,释放
});



点赞(3) 打赏

Comment list 共有 0 条评论

暂无评论

微信小程序

微信扫一扫体验

立即
投稿

微信公众账号

微信扫一扫加关注

发表
评论
返回
顶部