Node.js 连接 MySQL的具体操作

下载MySQL

• MySQL 下载地址
• 启动：系统偏好设置

连接MySQL

• Navicat下载
• Navicat 连接mysql
  
• 新建数据库
  
• 导入SQL文件
  
• 刷新查看
  
• 新建test.js文件

  var mysql = require('mysql');
  var connection = mysql.createConnection({
  host    : 'localhost',
  user    : 'root',
  password : 'yanmeiyan',
  database : 'wxypdata'
  });
  
  connection.connect();
  
  connection.query('SELECT 1 + 1 AS solution', function (error, results, fields) {
  if (error) throw error;
  console.log('The solution is: ', results[0].solution);
  });

• 执行命令

  $ node test.js

  出现

  The solution is: 2

  代表数据库连接成功

数据库操作

• 查询数据

  var  sql = 'SELECT * FROM websites';
  //查
  connection.query(sql,function (err, result) {
  if(err){
  console.log('[SELECT ERROR] - ',err.message);
  return;
  }
  
  console.log('--------------------------SELECT----------------------------');
  console.log(result);
  console.log('------------------------------------------------------------\n\n');
  });

  
• 插入数据

  var  addSql = 'INSERT INTO websites(Id,name,url,alexa,country) 			VALUES(0,?,?,?,?)';
  var  addSqlParams = ['菜鸟工具', 'https://c.runoob.com','23453', 'CN'];
  //增
  connection.query(addSql,addSqlParams,function (err, result) {
  if(err){
  console.log('[INSERT ERROR] - ',err.message);
  return;
  }
  
  console.log('--------------------------INSERT----------------------------');
  //console.log('INSERT ID:',result.insertId);
  console.log('INSERT ID:',result);
  console.log('-----------------------------------------------------------------\n\n');
  });

  
  
• 更新数据

  var modSql = 'UPDATE websites SET name = ?,url = ? WHERE Id = ?';
  var modSqlParams = ['菜鸟移动站', 'https://m.runoob.com',7];
  //改
  connection.query(modSql,modSqlParams,function (err, result) {
  if(err){
  console.log('[UPDATE ERROR] - ',err.message);
  return;
  }
  console.log('--------------------------UPDATE----------------------------');
  console.log('UPDATE affectedRows',result.affectedRows);
  console.log('-----------------------------------------------------------------\n\n');
  });

  
  
• 删除数据

  var delSql = 'DELETE FROM websites where id=7';
  //删
  connection.query(delSql,function (err, result) {
  if(err){
  console.log('[DELETE ERROR] - ',err.message);
  return;
  }
  
  console.log('--------------------------DELETE----------------------------');
  console.log('DELETE affectedRows',result.affectedRows);
  console.log('-----------------------------------------------------------------\n\n');
  });