初学nodejs 之 nodejs操作mysql

页面导航:首页 > 网络编程 > JavaScript > 初学nodejs 之 nodejs操作mysql

初学nodejs 之 nodejs操作mysql

来源: 作者: 时间:2016-02-02 09:59 【

1:npm获取mysql包打开cmd,cd到nodejs的安装目录,运行:npm install mysql。2:nodejs代码:var http = require( 39;http 39;),util = require( 39;util 39;),mysql = require( 39;mysql

1:npm获取mysql包

打开cmd,cd到nodejs的安装目录,运行:npm install mysql。

2:nodejs代码:

var http = require('http'),
	util = require('util'),
	mysql = require('mysql');



http.createServer(function(req,res){
	res.writeHead(200,{'Content-type':'text/'});
	var connection = .createConnection({
	  	host     : 'localhost',
	  	user     : 'root',
	  	password : 'sanyue'
	});
	var sql = [ 'set names utf8;',
			'create database if not exists nodejs;',
			'use nodejs;',
			'drop table if exists nodejs;',
			'create table nodejs ( id int(4), name char(12), age int(2));',
			'insert into nodejs values (1,"John",20),(2,"Tom",21);',
			'select * from nodejs;'
		  ];
	connection.query(sql[0],function(err,result,fields){
		if(err){
			res.write('Execute SQL: "'+sql[0]+'" failed!
'); res.write(util.inspect(err,true)); res.end(); }else{ res.write('Execute SQL: "'+sql[0]+'" successed!
'); } }); connection.query(sql[1],function(err,result,fields){ if(err){ res.write('Execute SQL: "'+sql[1]+'" failed!
'); res.write(util.inspect(err,true)); res.end(); }else{ res.write('Execute SQL: "'+sql[1]+'" successed!
'); } }); connection.query(sql[2],function(err,result,fields){ if(err){ res.write('Execute SQL: "'+sql[2]+'" failed!
'); res.write(util.inspect(err,true)); res.end(); }else{ res.write('Execute SQL: "'+sql[2]+'" successed!
'); } }); connection.query(sql[3],function(err,result,fields){ if(err){ res.write('Execute SQL: "'+sql[3]+'" failed!
'); res.end(); }else{ res.write('Execute SQL: "'+sql[3]+'" successed!
'); } }); connection.query(sql[4],function(err,result,fields){ if(err){ res.write('Execute SQL: "'+sql[4]+'" failed!
'); res.write(util.inspect(err,true)); res.end(); }else{ res.write('Execute SQL: "'+sql[4]+'" successed!
'); } }); connection.query(sql[5],function(err,result,fields){ if(err){ res.write('Execute SQL: "'+sql[5]+'" failed!
'); res.write(util.inspect(err,true)); res.end(); }else{ res.write('Execute SQL: "'+sql[5]+'" successed!
'); } }); connection.query(sql[6],function(err,result,fields){ if(err){ res.write('Execute SQL: "'+sql[6]+'" failed!
'); res.write(util.inspect(err,true)); res.end(); }else{ res.write('Execute SQL: "'+sql[6]+'" successed!
'); res.write('Result:
'+util.inspect(result,true)+'
'); res.end(); } }); }).listen(9999);

3:运行效果:

\

4:查看mysql结果:

\

Tags:

文章评论

最 近 更 新
热 点 排 行
Js与CSS工具
代码转换工具

<