Nodejs连接MySQL数据库 增、删、改、查等操作

MySQL 04/14 阅读 19 views次 人气 0
摘要:

Nodejs连接MySQL数据库 增、删、改、查等操作,Nodejs连接MySQL数据库 增、删、改、查等操作,Nodejs连接MySQL数据库 增、删、改、查等操作

数据库表

create table `e_customer`(
    `uuid` varchar(50) primary key,
    `customerId` varchar(100) comment '顾客ID',
    `customerName` varchar(100) comment '顾客名称',
    `customerSource` varchar(100) comment '顾客来源',
    `sourceSign` varchar(100) comment '来源标识',
    `sourceAddress` varchar(100) comment '来源地址', 
    `createTime` varchar(100) comment '创建时间'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;


nodejs连接mysql

// 安装 cnpm
// npm install -g cnpm --registry=https://registry.npm.taobao.org
// 安装 mysql
// cnpm install mysql


var mysql=require("mysql");

var connection=mysql.createConnection({
    host: '127.0.0.1',
    port: 3306,
    user: 'root',
    password: '123124',
    database: 'dorder'
});

connection.connect(function(err,result){
    console.log("\n\n\n\n\n\n\n\n\n\n");
    console.log(err);
    console.log(result);
    console.log("\n\n\n\n\n\n\n\n\n\n");
    //return result;
});


增、删、改的操作:

var mysql=require("mysql");

var mysql_config={
    host: '127.0.0.1',
    port: 3306,
    user: 'root',
    password: '123124',
    database: 'dorder'
}

var connection=mysql.createConnection(mysql_config);


function handleDisconnect(){
    connection.connect(function (err) {
        if(err){
            console.log(err);
            console.log("try to connect");
            setTimeout(handleDisconnect,1000);  //经过1秒后尝试重新连接
            return;
        }
        console.log("Success");
    });
}
handleDisconnect();


var inertSql="insert into `e_customer`(`uuid`,`customerId`,`customerName`,`customerSource`,`sourceSign`,`sourceAddress`,`createTime`) values(?,?,?,?,?,?,?)";
var inertSql_Params=['1001','zhangsan','张三','1','weixin0001','127.0.0.1','2019-04-14 15:09'];

connection.query(inertSql,inertSql_Params,function(err,result){
    if(err){
        throw err;
    }
    console.log('show result ->' + result);
    // 影响行数
    console.log('show result ->' + result.affectedRows);
});


connection.end();


查询操作:

var mysql=require('mysql');

var mysql_config={
    host: '127.0.0.1',
    port: 3306,
    user: 'root',
    password: '123124',
    database: 'dorder'
};

var connection=mysql.createConnection(mysql_config);

function handleDisconnect(){
    connection.connect(function (err) {
        if(err){
            console.log(err);
            console.log("try to connect");
            setTimeout(handleDisconnect,1000);  //经过1秒后尝试重新连接
            return;
        }
        console.log("Success");
    });
}
handleDisconnect();

connection.query("use dorder");

var querySql = "select * from `e_customer`";

connection.query(querySql,function(err,rows){
    if(err){
        throw err;
    }

    var jsonData = JSON.stringify(rows);
    console.log(jsonData);

    for(var i=0;i<rows.length;i++){
        console.log("uuid --> " + rows[i].uuid);
        console.log("customerId --> " + rows[i].customerId);
        console.log("customerName --> " + rows[i].customerName);
        console.log("customerSource --> " + rows[i].customerSource);
        console.log("sourceSign --> " + rows[i].sourceSign);
        console.log("sourceAddress --> " + rows[i].sourceAddress);
        console.log("createTime --> " + rows[i].createTime);
        console.log("\n");
    }
   
});

connection.end();


评论

表情
  1. 岁月安好 作者 人生最大的挑战没过于战胜自己!

    // 安装 cnpm // npm install -g cnpm --registry=https://registry.npm.taobao.org // 安装 mysql // cnpm install mysql

    2019/04/14 回复

分享到: