Node连接Mysql进行增删改查

安装Mysql模块

1	npm install mysql

注：由于不是全局安装，建议下面的文件也放在模块的同级目录中去

连接Mysql数据库

const mysql = require('mysql');
let connection = mysql.createConnection(
    {
        host : 'localhost',
        user : 'root',
        password :'123456',
        port: '3306',
        database : 'test'
    }
);
connection.connect((err, result) => {
    if (err) {
      console.log(err);
      console.log("连接失败");
      return;
    }
    console.log(result);
    console.log("连接成功");
  });
connection.end();

查询数据

et sql = 'select * from users_copy1';
connection.query(sql,(err,result)=> {
    if (err) {
      console.log('[SELECT 失败] - ', err.message);
      return;
    }
  
    console.log('--------------查询-------------');
    console.log('查询成功:',result);
    console.log('--------------------------\n\n');
  });
  connection.end();

插入数据

let Sql = 'INSERT INTO users_copy1(id,name,age,pwd,user_sex,info) VALUES(0,?,?,?,?,?)';
let SqlParams = ['东契奇', '21', '77','Man','player'];

connection.query(Sql, SqlParams, (err, result) => {
  if (err) {
    console.log('[增加失败] - ', err.message);
    return;
  }

  console.log('---------------插入-------------');
  console.log('增加成功 ID:',result.insertId);
  console.log('增加成功:', result);
  console.log('--------------------------------\n\n');
});

connection.end();

更新数据

let upSql = 'UPDATE users_copy1 SET name = ? WHERE id = ?';
let upSqlParams = ['卢卡', 0];

connection.query(upSql, upSqlParams,  (err, result) => {
  if (err) {
    console.log('[更新失败] - ', err.message);
    return;
  }
  console.log('------------更新---------------');
  console.log('更新成功', result.affectedRows);
  console.log('-------------------------------\n\n');
});
connection.end();

删除数据

let delSql = 'DELETE FROM users_copy1 where id=0';

connection.query(delSql, (err, result) => {
  if (err) {
    console.log('[删除失败] - ', err.message);
    return;
  }

  console.log('---------删除------------');
  console.log('删除成功', result.affectedRows);
  console.log('------------------------\n\n');
});

connection.end();

注意：五部分代码放在一个js文件即可使用，至于数据库sql可以参照插入的自己编一个