Node.js は mysql データベースを操作して、node.js の追加、削除、変更、query

Node.js は mysql データベースを操作して、node.js の追加、削除、変更、query_node.js を実行します。

WBOY

リリース： 2016-05-16 15:07:29

オリジナル

3265 人が閲覧しました

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');
});

ログイン後にコピー

データベース接続を閉じる

接続.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();

ログイン後にコピー