Node.js는 mysql 데이터베이스를 운영하여 추가, 삭제, 수정 및 query

Node.js는 mysql 데이터베이스를 운영하여 추가, 삭제, 수정 및 query_node.js를 수행합니다.

WBOY

풀어 주다： 2016-05-16 15:07:29

원래의

3266명이 탐색했습니다.

mysql 데이터베이스를 운영하는 node.js에 대한 소개 전문을 읽어보세요. 다음 소개는 매우 상세하며, 구체적인 내용은 다음과 같습니다.

mysql 모듈 설치

npm install mysql

로그인 후 복사

데이터베이스 준비

mysql 서버가 위치한 머신의 IP 주소는 192.168.0.108 입니다. 로그인하려면 root@123456을 사용하세요

mysql에서 테스트 데이터베이스 생성

테스트 데이터베이스에 사용자 테이블 생성

작전

데이터베이스에 연결

var mysql=require('mysql');
var connection = mysql.createConnection({
host : '192.168.0.108',
user : 'root',
password : '123456',
database : 'test1',
port:'3306'
});
connection.connect();

로그인 후 복사

사용자 삽입

var usr={name:'zhangsan',password:'pwdzhangsan',mail:'zhangsan@gmail.com'};
connection.query('insert into users set &#63;', usr, function(err, result) {
if (err) throw err;
console.log('inserted zhangsan');
console.log(result);
console.log('\n');
});

로그인 후 복사

조건으로 사용자 업데이트

connection.query('update users set password="ddd" where name="zhangsan"', {password:'ppp'}, function(err, result) {
if (err) throw err;
console.log('updated zhangsan\'s password to ddd');
console.log(result);
console.log('\n');
});

로그인 후 복사

조건이 있는 사용자 삭제

connection.query('delete from users where name="zhangsan"', {password:'ppp'}, function(err, result) {
if (err) throw err;
console.log('deleted zhangsan');
console.log(result);
console.log('\n');
});

로그인 후 복사

사용자 모두 조회

connection.query('select * from users', function(err, rows, fields) {
if (err) throw err;
console.log('selected after deleted');
for(var i= 0,usr;usr=rows[i++];){
console.log('user nae='+usr.name + ', password='+usr.password);
}
console.log('\n');
});

로그인 후 복사

데이터베이스 연결 닫기

connection.end()

기본 CRUD 완성

mysql 모듈의 전체 기능 설명은 공식 페이지를 참조하세요.

https://www.npmjs.com/package/mysql

https://github.com/felixge/node-mysql

모든 데모 코드

var mysql=require('mysql');
var connection = mysql.createConnection({
host : '192.168.0.108',
user : 'root',
password : '123456',
database : 'test1',
port:'3306'
});
connection.connect();
var usr={name:'zhangsan',password:'pwdzhangsan',mail:'zhangsan@gmail.com'};
connection.query('insert into users set &#63;', usr, function(err, result) {
if (err) throw err;
console.log('inserted zhangsan');
console.log(result);
console.log('\n');
});
connection.query('select * from users', function(err, rows, fields) {
if (err) throw err;
console.log('selected after inserted');
for(var i= 0,usr;usr=rows[i++];){
console.log('user nae='+usr.name + ', password='+usr.password);
}
console.log('\n');
});
connection.query('update users set password="ddd" where name="zhangsan"', {password:'ppp'}, function(err, result) {
if (err) throw err;
console.log('updated zhangsan\'s password to ddd');
console.log(result);
console.log('\n');
});
connection.query('select * from users', function(err, rows, fields) {
if (err) throw err;
console.log('selected after updated');
for(var i= 0,usr;usr=rows[i++];){
console.log('user nae='+usr.name + ', password='+usr.password);
}
console.log('\n');
});
connection.query('delete from users where name="zhangsan"', {password:'ppp'}, function(err, result) {
if (err) throw err;
console.log('deleted zhangsan');
console.log(result);
console.log('\n');
});
connection.query('select * from users', function(err, rows, fields) {
if (err) throw err;
console.log('selected after deleted');
for(var i= 0,usr;usr=rows[i++];){
console.log('user nae='+usr.name + ', password='+usr.password);
}
console.log('\n');
});
connection.end();

로그인 후 복사