首先推荐官方文档
https://www.npmjs.com/package/mysql

连接mysql数据库

从node库中引用mysql后,可以用createConnection()创建一个连接,需要将一些配置参数传给函数

var mysql      = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'me',
  password : 'secret',
  database : 'my_db'
});

数据库连接的建立与关闭

通过mysql.createConnection()后可以获得一个mysql connection对象,可以通过这个对象调用connect()或者end()来建立或关闭连接。

connection.connect();  // 连接建立
connection.end();      // 连接关闭

注意:由于在node中的网路请求是异步的,所以数据库查询操作也是异步的,通过一个任务队列来依次执行,所以end()并不会直接关闭,而是将存在任务队列中的任务都发送出去后再关闭。

以下是官网原文

  • Every method you invoke on a connection is queued and executed in sequence.
  • Closing the connection is done using end() which makes sure all remaining queries are executed before sending a quit packet to the mysql server.

数据库连接不关闭运行运行程序后程序是不会停止的,要手动Ctrl+C才会停止
这是一个官网建议的连接实例

var mysql      = require('mysql');
var connection = mysql.createConnection({
  host     : 'example.org',
  user     : 'bob',
  password : 'secret'
});
 
connection.connect(function(err) {
  if (err) {
    console.error('error connecting: ' + err.stack);
    return;
  }
 
  console.log('connected as id ' + connection.threadId);
});

简单的增删改查CURD

我现在有一个表,表中只有两个列

  1. id 自增主键
  2. name varchar类型
执行sql语句的方法
  1. 直接将要执行的sql语句放入
connection.query(`delete from test where id= 1`, (error, results) => {
    if (error) throw error;
    console.log(results);
});

2.用?替换sql执行时需要更改的参数
将需要作为参数的部分用?代替,在后面传入参数作为?依次顺序对应的值,需要注意的是,?替换进去的字符串值会被默认加上’ ‘,比如这个”测试问号”和2被替换进?后sql语句是这样的update test set name = '测试问号' where id = 2

connection.query(`update test set name = ? where id = ?`, ["测试问号", 2], (error, results) => {
    if (error) throw error;
    console.log(results);
});

3.设置执行参数
sql执行时可以带超时参数,替换?值参数

connection.query({
  sql: `update test set name = ? where id = ?`,
  timeout: 40000, // 40s
  values:  ["测试问号", 2]
}, function (error, results, fields) {
    if (error) throw error;
    console.log(results);
});
接着引用官方的连接实例来一个完整的增删查改:
var mysql      = require('mysql');
var connection = mysql.createConnection({
  host     : 'example.org',
  user     : 'bob',
  password : 'secret'
});
 
connection.connect(function(err) {
  if (err) {
    console.error('error connecting: ' + err.stack);
    return;
  }
 
  console.log('connected as id ' + connection.threadId);
});
// 增
connection.query(`insert into test(name) values(?)`,"测试",(error, results) =>{
    if (error) throw error;
    console.log(results);
});

// 删
connection.query(`delete from test where id= ?`,1,(error, results) =>{
    if (error) throw error;
    console.log(results);
});

// 查
connection.query('SELECT * from test', function (error, results, fields) {
    if (error) throw error;
    console.log("查询结果是");
    console.log(results);
});

// 改

connection.query(`update test set name = "测试修改" where id = 2`,(error, results) =>{
    if (error) throw error;
    console.log(results);
});

// 关闭连接
connection.end();

运行结果:

connected as id 286718
OkPacket {
  fieldCount: 0,
  affectedRows: 1,
  insertId: 5,
  serverStatus: 2,
  warningCount: 0,
  message: '',
  protocol41: true,
  changedRows: 0 }
OkPacket {
  fieldCount: 0,
  affectedRows: 1,
  insertId: 0,
  serverStatus: 2,
  warningCount: 0,
  message: '',
  protocol41: true,
  changedRows: 0 }
查询结果是
[ RowDataPacket { id: 2, name: 'change Hellow JabinGP again' },
  RowDataPacket { id: 3, name: '测试' },
  RowDataPacket { id: 4, name: '测试' },
  RowDataPacket { id: 5, name: '测试' } ]
OkPacket {
  fieldCount: 0,
  affectedRows: 1,
  insertId: 0,
  serverStatus: 2,
  warningCount: 0,
  message: '(Rows matched: 1  Changed: 1  Warnings: 0',
  protocol41: true,
  changedRows: 1 }

文章来源于互联网:在Node.js中使用Mysql数据库(二)连接和操作数据库

发表评论