Nodejs搭配Mysql

终于有一天，自己开始主动写demo和总结。
来看看怎么用强大的Nodejs来操作数据库吧。

安装mysql的过程就不说啦，直接看我的数据库结构吧

用户信息表

1.连接数据库

//connect.js
const mysql = require("mysql");

const connection = mysql.createConnection({
    host: "localhost",  //主机地址
    user: "root", //数据库用户名
    password: "123456", //数据库用户密码
    database: "test"  //数据库名
});

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 connect.js
出现The solution is: 2表示连接成功

2.增加用户
先连接数据库再定义增加用户的模板

//userInsert.js
const mysql = require("mysql");

const connection = mysql.createConnection({
    host: "localhost",
    user: "root",
    password: "123456",
    database: "test"
});

connection.connect();
//连接之后进行插入操作

const addSql = 'insert user (id,name,sex,age,tel,mail,note) values(?,?,?,?,?,?,?)';
const addSqlParams = [null,"孙","man",13,"1234567","234567@qq.com","fghavi"];

connection.query(addSql,addSqlParams,function (err,result) {
    if(err){
        console.log('[INSERT ERROR] - ',err.message);
        return;
    }

    console.log('INSERT ID:',result);
});

connection.end();

执行node userInsert.js

插入执行结果g

3.查询操作
查询操作也要先链接数据库再对数据库进行操作

const mysql = require("mysql");

const connection = mysql.createConnection({
    host: "localhost",
    user: "root",
    password: "123456",
    database: "test"  
});

connection.connect();
//连接之后进行查询操作

const sql = "select * from user"; //选择所有
connection.query(sql,function (err, result) {
    if(err){
        console.log('[SELECT ERROR] - ',err.message);
        return;
    }
    console.log(result);
});  //输出查询结果

connection.end();

查询操作结果

4.更新操作
根据数据库的主键进行查询更新

//userUpdate.js
//连接数据库与之前的相同  连接之后进行修改
const modSql = "update user set name=?,sex=?,age=?,tel=?,mail=?,note=? where id = ?";
 //根据id进行修改
const modSqlParams = ["及","woman",32,"345678","ndsajvn@qq.com","adsvfadsv",2];
//修改后的内容

connection.query(modSql,modSqlParams,function (err, result) {
    if(err){
        console.log('[UPDATE ERROR] - ',err.message);
        return;
    }
    console.log('UPDATE success',result.affectedRows);
});
//输出更新是否成功
connection.end();

更新操作

可以再对数据库进行查询判断是否更新成功

5.数据库删除
根据数据库主键对某一条记录进行删除操作

//userDelete.js
//l数据库连接之后进行删除操作

const delSql = 'delete from user where id = "4"';
//根据id删除
connection.query(delSql,function (err, result) {
    if(err){
        console.log('[DELETE ERROR] - ',err.message);
        return;
    }
    console.log('DELETE success',result.affectedRows);
});
connection.end();

执行node userDelete.js 可以看到删除结果，也可以通过数据库查询再判断是否删除成功。

6.遇到的问题

• musql无法显示中文
  alter table tbl_name convert to character set utf8;

就这么多啦～