文档章节

Nodejs连接mysql数据库

webphp
 webphp
发布于 2017/07/26 11:28
字数 576
阅读 9
收藏 0
学习Nodejs第三天,连接mysql数据库进行用户注册,看到网上nodejs搭配的是mongodb,可惜没有学习mongodb,只好用比较熟悉的mysql,只是个人用的方法,不喜勿喷(用的express) 第一步用php一样,先写mysql的配置文件,在站点根目录下创建conf文件夹,创建db.js
module.exports = {
    mysql: {
        host: '127.0.0.1', 
        user: 'root',
        password: '',
        database:'nodejs', 
        port: 3306
    }
};
 第二部创建SQL语句因为本人用的是express可以像php的mvc模式那样操作,所以在站点根目录下创建model文件夹,然后创建文件userSqlMapping.js
// userSqlMapping.js
// CURD SQL语句
var user = {
	insert : 'INSERT INTO user (id, username, password) VALUES(0,?,?)',
	update : 'UPDATE user SET username = ?, password = ? WHERE id = ?',
	delete : 'DELETE FROM user WHERE id = ?',
	queryById : 'SELECT * FROM user WHERE id = ?',
	queryAll : 'SELECT * FROM user'
};
module.exports = user;
在这里要用到util/util.js
// util.js

module.exports = {
	extend : function( target, source, flag){
		for(var key in source){
			if (source.hasOwnProperty(key)) {
				flag ? (target[key] = source[key]) : (target[key] === void 0 && (target[key] = source[key]));

			};
		}
		return target;
	}
}
/util/unil_string.js(这是对程序逻辑操作,字符串操作类,与连接mysql数据库无关)
// string.js
//md5加密解决中文加密不一样的bug
exports.md5 = function md5(data) {
    var Buffer = require("buffer").Buffer;
    var buf = new Buffer(data);
    var str = buf.toString("binary");
    var crypto = require("crypto");
    return crypto.createHash("md5").update(str).digest("hex");
 }
创建userModel.js
// userModel.js
//实现与MySql交互
var mysql = require('mysql');
var $conf = require('../config/db');//引入配置文件
var $util = require('../util/util');
var $util_string = require('../util/string');//处理字符的函数库
var $sql = require('./userSqlMapping');

//使用连接池,提升性能
var pool = mysql.createPool($util.extend({}, $conf.mysql));

module.exports = {
	add : function(req, res, callback){
		pool.getConnection(function(err, connection){
			//获取前台页面传过来的参数
			var post_data = req.body.user
		 	var username = post_data.username;
		 	var password = post_data.password;
		 	//md5加密密码
		 	md5_passwd = $util_string.md5(password);
			//建立连接,向表中插入数据
			connection.query($sql.insert, [username, md5_passwd], function(err, result){
				if ( result ) {
					result = {
						code:200,
						msg:'增加成功',
						data: result,
					}
				}else{
					result = {
						code:0,
						msg:'增加失败',
					}
				}

				//释放连接
				connection.release();
				//能过回调函数返回到前台
				callback(err, result);

			})
		})
	}
}
这样就连接成功数据库,并可以对数据库进行curd操作了,jade中的注册页面可以查看 http://www.webipcode.com/archives/248 然后在app.js的设置路由,要用post(因为在表单中进行的post提交) /routes/user.js
//用户注册
 exports.reg = function(req, res){
	userModel.add(req, res, function(err,result){
		if ( result.code == 200 ) {
			setTimeout(function(){
				res.redirect('/');
			},2500);
			return ;
		}else{
			setTimeout(function(){
				res.redirect('/');
			},2500);
			return ;
		}


	});
	
 }
这样用户注册与mysql数据交互就完成了。

© 著作权归作者所有

共有 人打赏支持
webphp
粉丝 1
博文 92
码字总数 92338
作品 0
海淀
程序员
nodejs 连接Mysql相关操作的示例代码

最近在搞nodejs,要做一些数据库的相关操作,数据库用的是Mysql,网上也有不少代码,红薯也一篇博文说明了相关操作,但是拿来用的时候,发现了一些小问题,仔细研究,红薯提供的代码是官方的...

Eric_HSBC
2013/09/21
0
0
nodejs 连接Mysql相关操作的示例代码

最近在搞nodejs,要做一些数据库的相关操作,数据库用的是Mysql,网上也有不少代码,红薯也一篇博文说明了相关操作,但是拿来用的时候,发现了一些小问题,仔细研究,红薯提供的代码是官方的...

maweitao
2014/04/03
0
0
nodejs 连接Mysql相关操作的示例代码(orm)

上一篇博文写了nodejs 连接Mysql相关操作的示例代码,主要用到的是sql语句,都是比较基础的。这篇打算介绍一下nodejs的ORM操作,毕竟大型系统的开发还是需要用到ORM. nodejs里有不少的ORM框架...

Eric_HSBC
2013/09/28
0
1
node.js 开发指南 – Node.js 连接 MySQL 并进行数据库操作

ode.js是一套用来编写高性能网络服务器的JavaScript工具包 通常在NodeJS开发中我们经常涉及到操作数据库,尤其是 MySQL ,作为应用最为广泛的开源数据库则成为我们的首选,本篇就来介绍下如何...

james_laughing
2016/12/14
4
0
基于Nodejs开发的web即时聊天工具

由于公司需要开发web即时聊天工具,开始时我们主要的实施方法是用jquery的ajax定时(10秒)轮询向服务器请求,由于是轮询请求,对服务器的压力比较大。我们网站上线的时间不长,访问量不是很...

Jackwoo
2013/03/12
0
5

没有更多内容

加载失败,请刷新页面

加载更多

使用JDK自带的jmap和jhat监控处于运行状态的Java进程

对于处于运行状态中的Java进程,JDK自带了很多工具,允许Java开发人员监控运行进程中的各种状态,比如该进程内部创建了多少个对象实例,消耗了多少内存,等等。 本文基于JDK1.8而写成。 我下...

JerryWang_SAP
13分钟前
1
0
下单接口调优实战,性能提高10倍

概述 最近公司的下单接口有些慢,老板担心无法支撑双11,想让我优化一把,但是前提是不允许大改,因为下单接口太复杂了,如果改动太大,怕有风险。另外开发成本和测试成本也非常大。对于这种...

Sam哥哥聊技术
46分钟前
2
1
rabbitMQ的安装和配置

在Windows下进行rabbitMQ的安装 第一步:软件下载 在安装rabbitMQ之前,需要先安装Erlang。 Erlang官网:http://www.erlang.org/downloads rabbitMQ官网:http://www.rabbitmq.com/download....

狼王黄师傅
今天
3
0
Vue-Element-Upload

记录一下文件上传封装Js 代码示例 封装:uploadFile.vue <template> <el-upload v-model="attachment" ref="upload" class="upload-demo" :action="uploadUrl" ......

华山猛男
今天
4
0
AWVS破解及使用手册

1.安装 因为是windows软件,比较简单,此部分略: 破解插件下载: 链接: https://pan.baidu.com/s/1x9LK9F3KvqDgTvXDjoSZnQ 提取码: 7k4u 2.创建扫描目标 2-1.Targets->Add Target 2-2.对话框...

硅谷课堂
今天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部