产品开发了新版本，数据不兼容，新版本的数据结构比旧版本复杂一些，目前，旧版本是在线系统，需要将旧版本程序的数据适配至新版本程序。数据库是MySQL，这里选择使用NodeJS来完成。

nodejs数据库 nodejs数据库增删改查

nodejs数据库 nodejs数据库增删改查

使用的版本：

需要的依赖

案例一，单表的数据同步：

databasemysqlmysql.tools.js

databasemysql2mysql2.tools.js

syncdata0.basesyncData.js

syncdata1.manufactormain.manufactor.js

syncdata2.brandmain.brand.js

syncdata3.categorymain.category.js

案例二，关联表的数据同步：

databasemysql2mysql2.promise.tools.js

syncdata4.general_namemain.general_name.js

syncdata5.goodain.goods.js

NodeJS对mysql数据库的简单作

1.

打开软件新建一个空的文件夹

2.

然后引入mysql依赖 npm install mysql 1 完成后对应文件夹下会生成一个node_modules的文件夹,我们不需要去管它

3.

编写mysql.js文件 // 导入mysql依赖constmysql=require("mysql")// 获取

首先这取决于你的首屏是怎么渲染的。

1、端渲染：

后台把数据按照格式拼成html字符串（端模板引擎最终也干的是这个，不过是更优雅而已），最终生成完整html文件。

2、客户端渲染：

html文件只包含静态的内容，客户端打开html后再发起ajax请求去后台请求数据，前台拿到数据拼html字符串查到html文件里（同上，客户端模板引擎最终也干的是这个，不过是更优雅而已）。

nodejs数据存mongodb：

首先创建数据库保存用户信息

数据库创建名 users 并插入条用户信息前没 users mongodb 直接创建

> db.users.insert( { "userId":1, "name":"tom", "email":"" })

查找信息使用 find 或者 findOne区别于 findOne 返结

db.users.findOne( {"userId": 1})

返结：

{"_id" : ObjectId("5413be6e9e1c9f9c4386756d"),

"userId" : 1,

"name" : "tom",

"email" : ""

}驱程序

编辑 package.json, 添加于 mongodb 引用

{"name": "express-api",

"version": "0.0.1",

"dependencies": {

"express": "2.5.9",

"ejs": "0.4.2",

"mongodb": "1.4.1"

}}

重新 npm install 安装 mongodb 驱

使用 MongoDB 数据库

修改代码首先 require mongodb 模块连接 mongodb 数据库

var mongo = require("mongodb");

var express = require("express");

var app = express.create();

app.set("view engine", "ejs");

app.set("views", __dirname + "/views");

app.set("view options", { layout: false });

app.get("/", function (request, response) {

response.render("index");

});

app.get("/user/:id", function (request, response) {

var id = request.params.id;

console.log(id);

app.users.findOne({ "userId": +id }, function (error, doc) {

if (error) return next(error);

response.json(doc);

});

});

// connect mongodb

var server = new mongo.("127.0.0.1", 27017);

var db = new mongo.Db("members", server, {safe:true }).open(function (error, client) {

if (error) throw error;

console.log("033[96m + 033[39m connected to mongodb");

app.users = new mongo.Collection(client, "users");

client.ensureIndex("users", "userId", function (error) {

if (error) throw error;

console.log("033[96m + 033[39m ensured index.");

console.log("Web listening ......");

app.listen(3000);

});

});

注意现数据库查找用户id 前面 + 用表单字符串类型数据转换需要数字类型

app.users.findOne({ "userId": +id }, function (error, doc) {

if (error) return next(error);

response.json(doc);

});

nodejs简单访问及作mysql数据库的方法示例

本文实例讲述了nodejs简单访问及作mysql数据库的方法。分享给大家供大家参考，具体如下：

var

mysql

=require('mysql');

//调用MySQL模块

mysql模块要安装

$npm

install

mysql

//创建一个connection

var

connection

=mysql.createConnection({

host

:'127.0.0.1',

//主机

user

:'root',

//MySQL认证用户名

password

:'',

//MySQL认证用户密码

port:

'3306',

//端口号

database:''

//数据库名

});

//创建一个connection

connection.connect(function(err){

if(err){

console.log('[query]

-:'+err);

return;

}console.log('[connection

connect]

succeed!');

});

//执行SQL语句

connection.query('SELECT

1+

1AS

solution',

function(err,

rows,

fields)

{if

(err)

{console.log('[query]

-:'+err);

return;

}console.log('The

solution

is:

',

rows[0].solution);

});

//关闭connection

connection.end(function(err){

if(err){

return;

}console.log('[connection

end]

succeed!');

});

注：nodejs在作数据库的时候不用设置数据库的编码格式

set

names

utf8

希望本文所述对大家nodejs程序设计有所帮助。

您可能感兴趣的文章:nodejs连接mysql数据库简单封装示例-mysql模块nodejs进阶(6)—连接MySQL数据库示例nodejs实现的连接MySQL数据库功能示例Nodejs连接mysql并实现增、删、改、查作的方法详解nodeJs实现基于连接池连接mysql的方法示例nodejs中作mysql数据库示例NodeJS链接MySql数据库的作方法Nodejs使用mysql模块之获得更新和删除影响的行数的方法NodeJs使用Mysql模块实现事务处理实例nodejs连接mysql数据库及基本知识点详解