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

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;

就这么多啦～