nodejs如何操作数据库

‘壹’ node.js怎么把数据存入数据库

nodejs数据存mongodb：
首先创建数据库保存用户信息
数据库创建名 users 集合并插入条用户信息前没 users 集合mongodb 直接创建
> db.users.insert( { "userId":1, "name":"tom", "email":"[email protected]" })
查找信息使用 find 或者 findOne区别于 findOne 返结
db.users.findOne( {"userId": 1})
返结：
{
"_id" : ObjectId("5413be6e9e1c9f9c4386756d"),
"userId" : 1,
"name" : "tom",
"email" : "[email protected]"
}
驱程序
编辑 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.createServer();
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.Server("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 Server 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，可以使用Nodejs的MysQL驱动来实现。比如，我们这里使用“node-mysql”连接数据库。我们使用下面的方式来连接数据库：
首先，我们需要使用nodejs的包管理工具（npm）安装mysql的驱动。命令行如下：

[plain] view plain
npm install musql

现在，要在js文件中使用mysql，添加下面的代码到你的文件中：

[plain] view plain

‘叁’ 页面怎么用node.js调用mdb数据库

1、跨进程通信
新版的nodejs里增加了对子进程的操作，跨进程通信不是问题。
http://nodejs.org/docs/latest/api/all.html#child_Processes

复制代码 代码如下:

var util = require('util'),
exec = require('child_process').exec,
child;

child = exec('cat *.js bad_file | wc -l',
function (error, stdout, stderr) {
console.log('stdout: ' + stdout);
console.log('stderr: ' + stderr);
if (error !== null) {
console.log('exec error: ' + error);
}
});

如例我们可以拿到控制台的输出内容stdout！

2、数据库访问相关ActiveX，ADODB.Connection
参考：http://msdn.microsoft.com/en-us/library/windows/desktop/aa746471%28v=vs.85%29.aspx

复制代码 代码如下:

var connection = new ActiveXObject("ADODB.Connection");
var result = 'ok';
try{
connection.Open("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + params.accessfile);
connection.Execute(params.sql);
} catch(ex){
result = ex.message;
}
return {
result: result
};

connection.Open(connectionString)，链接字符串参数可以设置访问sql server。
参考：http://www.connectionstrings.com/sql-server-2005
3、为方便维护，特别将cscript和nodejs的脚本合并，用typeof exports判断当前运行环境。
4、字符编码cscript代码使用ascii编码
非ascii码字符进行“\uHHHH”Unicode编码。
5、命令行字符需转义，双引号、百分号在命令行有特殊意义。
参数传递使用base64编码，避免冲突
cscript环境MSXML2.DOMDocument可以做base64编解码

复制代码 代码如下:

function base64Decode(base64){
var xmldom = new ActiveXObject("MSXML2.DOMDocument");
var adostream = new ActiveXObject("ADODB.Stream");
var temp = xmldom.createElement("temp");
temp.dataType = "bin.base64";
temp.text = base64;

adostream.Charset = "utf-8";
adostream.Type = 1; // 1=adTypeBinary 2=adTypeText
adostream.Open();
adostream.Write(temp.nodeTypedValue);
adostream.Position = 0;
adostream.Type = 2; // 1=adTypeBinary 2=adTypeText
var result = adostream.ReadText(-1); // -1=adReadAll
adostream.Close();
adostream = null;
xmldom = null;
return result;
}

‘肆’ 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
+
1
AS
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数据库及基本知识点详解

‘伍’ nodejs使用Sequelize框架操作数据库

使用该方法可以定义model，例子如下：

该方法传入的第一个参数是数据表的单数形式，怎么理解呢？例如这里传入的是website其实是模型名，数据表默认是websites这样的复数形式，这种约定我在Laravel中也碰见过，
也就是常说的，约定大于定义，也就是说，如果我们都按照约定的规范去开发，那么效率其实比重新定义，要高很多。
那么，定义好了模型，该怎么进行使用呢？

我比较推荐使用继承Model这种方式，通过创建一个class，这样可以使用model.exports=模块名的方式，将该模型封装起来。供别的地方使用，只需要require进去即可。

具体如何对数据表进行操作，就比较简单了，只需要参考API即可。 sequelize文档地址

‘陆’ 如何在nodejs中通过web访问数据库

1、安装node.js、mysql，此处略（自行搜索吧）…；
2、创建一个名为test的数据库，然后建一张名为user_info的表（仅供测试）…
这里假定mysql使用的用户名为root，密码为123456
相应的mysql如下：
复制代码 代码如下:

/**
* 创建名为test的数据库
*/
DROP DATABASE IF EXISTS test;
CREATE DATABASE test;
USE test;

/**
* 创建user_info表
*/
DROP TABLE IF EXISTS `user_info`;
CREATE TABLE `user_info` (
`userId` int(10) NOT NULL AUTO_INCREMENT,
`userName` varchar(20) DEFAULT NULL,
PRIMARY KEY (`userId`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8;
/**
* 插入三条记录
*/
INSERT INTO user_info VALUES (NULL, '张一'), (NULL, '张二'), (NULL, '张三');

3、创建存储过程(写的很冗余，故意的… 正好学习一下语法>_<)；
复制代码 代码如下:

DELIMITER $$
DROP PROCEDURE IF EXISTS `test`.`proc_simple`$$
CREATE PROCEDURE proc_simple(IN uid INT(10), OUT uName VARCHAR(2), OUT totalCount INT)
BEGIN
DECLARE str_name VARCHAR(20);
SET @str_name = '';
SET totalCount = 0;
SELECT COUNT(1),userName INTO totalCount,@str_name FROM user_info WHERE userId = uid;
SET uName = @str_name;
SELECT uName, totalCount;

END$$
DELIMITER ;
4、写程序进行调用(假定存为名为sql.js的文件)；
复制代码 代码如下:

/**
* Created with JetBrains WebStorm.
* User: Meteoric_cry
* Date: 12-12-28
* Time: 上午00:18
* To change this template use File | Settings | File Templates.
*/
var mysql = require('mysql');
var connection = mysql.createConnection({
host : 'localhost',
port : 3306,
user : 'root',
password : '123456',
database : 'test',
charset : 'UTF8_GENERAL_CI',
debug : false
});
connection.connect();
connection.query('CALL proc_simple(1, @a, @b);', function(err, rows, fields) {
if (err) {
throw err;
}
var results = rows[0];
var row = results[0];
console.log("userName：",row.uName, "count：", row.totalCount);
});
connection.end();

‘柒’ nodejs怎么后台操作mysql

连接流程代码如下：

var mysql = require('mysql'); //调用MySQL模块//创建一个connectionvar connection = mysql.createConnection({

host : '127.0.0.1', //主机
user : 'root', //MySQL认证用户名
password:'12345',
port: '3306',
database: 'node'});//创建一个connectionconnection.connect(function(err){

if(err){

console.log('[query] - :'+err); return;

}

console.log('[connection connect] succeed!');

});

//执行SQL语句connection.query('SELECT 1 + 1 AS solution', function(err, rows, fields) {

if (err) {

console.log('[query] - :'+err); return;

}

console.log('The solution is: ', rows[0].solution);

});

//关闭connectionconnection.end(function(err){

if(err){

return;

}

console.log('[connection end] succeed!');

});

关于Connection Optionos

要想创建一个数据库连接，先就要认识清楚Options

host：主机地址 （默认：localhost）

user：用户名

password：密码

port：端口号 （默认：3306）

database：数据库名

charset：连接字符集（默认：’UTF8_GENERAL_CI’，注意字符集的字母都要大写）

localAddress：此IP用于TCP连接（可选）

socketPath：连接到unix域路径，当使用 host 和 port 时会被忽略

timezone：时区（默认：’local’）

connectTimeout：连接超时（默认：不限制；单位：毫秒）

stringifyObjects：是否序列化对象（默认：’false’ ；与安全相关https://github.com/felixge/node-mysql/issues/501）

typeCast：是否将列值转化为本地JavaScript类型值 （默认：true）

queryFormat：自定义query语句格式化方法https://github.com/felixge/node-mysql#custom-format

supportBigNumbers：数据库支持bigint或decimal类型列时，需要设此option为true （默认：false）

bigNumberStrings：supportBigNumbers和bigNumberStrings启用 强制bigint或decimal列以JavaScript字符串类型返回（默认：false）

dateStrings：强制timestamp,datetime,data类型以字符串类型返回，而不是JavaScript Date类型（默认：false）

debug：开启调试（默认：false）

multipleStatements：是否许一个query中有多个MySQL语句 （默认：false）

flags：用于修改连接标志，更多详情：https://github.com/felixge/node-mysql#connection-flags

ssl：使用ssl参数（与crypto.createCredenitals参数格式一至）或一个包含ssl配置文件名称的字符串，目前只捆绑Amazon RDS的配置文件

其它：

可以使用URL形式的加接字符串，不多介绍了，不太喜欢那种格式，觉得可读性差，也易出错，想了解的可以去主页上看。

MYSQL CURD操作

增加

var mysql = require('mysql');var DATABASE = "seckill";var TABLE="seckill"var connection = mysql.createConnection({
host:'127.0.0.1',
user:'root',
password:'12345',
port:'3306',
database: DATABASE
});

connection.connect();var addVip = 'insert into seckill(name,number) values(?,?)';var param = ['100元秒杀家教机',100];
connection.query(addVip, param, function(error, result){
if(error)
{
console.log(error.message);
}else{
console.log('insert id: '+result.insertId);
}
});

connection.end();

删除

var mysql = require('mysql');var DATABASE = "node";var TABLE="seckill"var connection = mysql.createConnection({
host:'127.0.0.1',
user:'root',
password:'12345',
port:'3306',
database: DATABASE
});

connection.connect();var addVip = 'delete from seckill where seckill_id = 1005';
connection.query(addVip, function(error, result){
if(error)
{
console.log(error.message);
}else{
console.log('affectedRows: '+result.affectedRows);
}
});

connection.end();

查找

var mysql = require("mysql");var DATABASE = "node";var TABLE="seckill"var connection = mysql.createConnection({
host:'127.0.0.1',
user:'root',
password:'12345',
port:'3306',
});

connection.connect();
connection.query('use '+DATABASE);
connection.query('select * from '+TABLE, function(error, results, fields){
if (error) { throw error;
} if (results) { for(var i = 0; i < results.length; i++)
{
console.log('%s %s',results[i].name,results[i].end_time);
}
}
});

connection.end();

修改

var mysql = require('mysql');var DATABASE = "seckill";var connection = mysql.createConnection({
host:'127.0.0.1',
user:'root',
password:'12345',
port:'3306',
database: DATABASE
});
connection.connect();var userSql = "update seckill set number = number-1 where seckill_id = ?";var param = [1000, 2];
connection.query(userSql, param, function (error, result) {
if(error)
{
console.log(error.message);
}else{
console.log('affectedRows: '+result.affectedRows);
}
});
connection.end();

结束连接其实有两种方法end()，destory()；

• end()
  end()方法在queries都结束后执行，end()方法接收一个回调函数，queries执行出错，仍然后结束连接，错误会返回给回调函数err参数，可以在回调函数中处理！

• destory()
  比较暴力，没有回调函数，即刻执行，不管queries是否完成！

使用连接池

在数据库中执行如下代码创建一个存储过程

• DROP PROCEDURE IF EXISTS `P_SeckillInfo`;DELIMITER ;;CREATE DEFINER=`root`@`localhost` PROCEDURE `P_SeckillInfo`(IN ExtName VARCHAR(120),IN ExtNumber INT(11),OUT ExtReturnVal INT)



• TOP: BEGIN



• DECLARE EXIT HANDLER FOR SQLEXCEPTION BEGIN



• ROLLBACK;



• SET ExtReturnVal = 0; -- Failed



• END;



• START TRANSACTION;



• INSERT INTO seckill(name, number) VALUES(ExtName,ExtNumber);



• SET ExtReturnVal = 1;



• SELECT ExtReturnVal;



• COMMIT;END;;



• DELIMITER ;262728293031323334



调用示例：

• var mysql = require("mysql");var pool = mysql.createPool({


• host: '127.0.0.1',



• user: 'root',



• password:'12345',



• port:'3306',



• database:'node'});//监听connection事件pool.on('connection', function(connection) {



• connection.query('select * from seckill', function(error, results, fields){


• if (error) { throw error;


• } if (results) { for(var i = 0; i < results.length; i++)


• {


• console.log('%s %s',results[i].name,results[i].end_time);


• }


• }


• });



• });//连接池可以直接使用，也可以共享一个连接或管理多个连接（引用官方示例）//直接使用pool.query('SELECT 1 + 1 AS solution', function(err, rows, fields) {



• if (err) throw err;



• console.log('The solution is: ', rows[0].solution);



• });//共享连接function myQuery(sql){


• pool.getConnection(function(err, connection) {



• connection.query(sql, function(err, result) {



• console.log(result); //释放连接


• connection.release();



• }); //Error: Connection already released,应该每次到连接池中再次获取


• // connection.query( 'SELECT * FROM seckill;', function(err, result) {




• // console.log(result);



• // connection.release();



• // });



• });


• }



• myQuery('SELECT * FROM seckill;');


• myQuery('SELECT * FROM seckill;');



1.连接池的创建，使用createPool方法，options和createConntion一致；
2.其它连接池配置选项

• waitForConnections

当连接池没有连接或超出最大限制时，设置为true且会把连接放入队列，设置为false会返回error

• connectionLimit
  连接数限制，默认：10

• queueLimit
  最大连接请求队列限制，设置为0表示不限制，默认：0

断开重连

示例代码：

• var mysql = require('mysql');var db_config = {



• host: '127.0.0.1',



• user: 'root',



• password:'12345',



• port:'3306',



• database:'node'};var connection;function handleDisconnect() {



• connection = mysql.createConnection(db_config);



• connection.connect(function(err) {



• if(err) {



• console.log('进行断线重连：' + new Date());



• setTimeout(handleDisconnect, 2000); //2秒重连一次


• return;



• }



• console.log('连接成功');



• });



• connection.on('error', function(err) {



• console.log('db error', err); if(err.code === 'PROTOCOL_CONNECTION_LOST') {



• handleDisconnect();



• } else {


• throw err;


• }



• });



• }



• handleDisconnect();



首先关闭mysql服务，然后执行程序，会一直打印断线重连，当再次开启mysql服务后，打印连接成功。

‘捌’ nodejs怎么连接数据库mysql

var mysql = require('mysql');
var conn = mysql.createConnection({
host: 'localhost',
user: 'root',
password: '',
database:'nodejs',
port: 3306
});
conn.connect();

//查询
// conn.query('SELECT * from user where name="wangwei"', function(err, result) {
// if (err) throw err;
// console.log(result);
// })

//新增
// conn.query('insert into user (username,password) values("huxiaona","123456")', function(err, result) {
// if (err) throw err;
// console.log(result);
// })

//删除
// conn.query('delete from user where username="wupeigui"', function(err, result) {
// if (err) throw err;
// console.log(result);
// })

conn.query('update user set id="1" where username="huxiaona"',function(err,result){
if (err) {throw err};
console.log("修改数据成功");
})

conn.end();