<h2>1.數(shù)據(jù)庫</h2>
數(shù)據(jù)庫命令:

mysql -u root -p          //進(jìn)入數(shù)據(jù)庫
create  database 庫名;    //創(chuàng)建數(shù)據(jù)庫
show databases;          //顯示數(shù)據(jù)庫
use 數(shù)據(jù)庫名;             //選擇數(shù)據(jù)庫
create table <表名> (<字段名1> <類型1> [,..<字段名n> <類型n>])   //創(chuàng)建數(shù)據(jù)表

enter.png

connection.jpg

<h2>2.JS文件</h2>
<h4>2.1 連接數(shù)據(jù)庫</h4>

var mysql = require('mysql');
var connection = mysql.createConnection({
    host: 'localhost',         //主機(jī)地址
    user: 'root',                //用戶名
    password: 'root',        //密碼
    database: 'test',        //數(shù)據(jù)庫名
    port: 3306                //端口號（默認(rèn)3306）
});
connection.connect();

connection.query('SELECT 1+1 AS solution',function (error,results,fields) {
    if(error) throw error;
    console.log('the solution is:',results[0].solution);
});

connection.png

<h4>2.2 添加數(shù)據(jù)</h4>

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

var addSql = 'INSERT INTO mytest(ID,name,sex) VALUES(0,?,?)';
var addSqlParams = ['aa', 'cc'];
connection.query(addSql, addSqlParams, function (err, result) {
    if (err) {
        console.log('err');
        return;
    }
    console.log('INSERT ID:', result);
});

connection.end();

重新打開一個終端，運(yùn)行 main.js 文件，如圖所示，添加成功，然后查詢數(shù)據(jù)庫：

show.png

 select * from mytest; //查詢數(shù)據(jù)

insert.png

<h4>2.3 刪除數(shù)據(jù)</h4>

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

connection.query('DELETE FROM mytest where id=1',function (err,result) {
    if(err){
        console.log('err');
        return
    }
    console.log('DELETE affectedRows',result.affectedRows);
})

connection.end();

運(yùn)行文件，打開數(shù)據(jù)庫查詢結(jié)果：

result.png

delete.png

<h4>2.4 修改數(shù)據(jù)</h4>

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

connection.query('UPDATE mytest SET name=? where id=2','change',function (err,result) {
    if(err){
        console.log(err);
        return
    }
    console.log('update affectedRows:',result.affectedRows);
});

connection.end();

運(yùn)行文件，查看結(jié)果：

result.png

update.png

<h4>2.5 查看數(shù)據(jù) </h4>

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

connection.query('select * from mytest',function (err,result) {
    if(err){
        console.log('err');
    }
    console.log(result)
});

connection.end();

運(yùn)行文件，查看結(jié)果：

show.png