noodjs(koa)+mysql搭建服務器環境及基本的增刪改查操作

手動創建項目文件

1.在指定目錄下，右擊創建項目文件夾。
2.使用git init 命令把此文件下內容變成可由git進行版本控制的文件。
3.執行“npm init -y”命令，創建package.json文件，初始化
4.執行“npm init koa”命令，安裝koa，此時項目路徑下會生成一個package-lock.json文件。

創建server

1.創建一個app.js文件，然后將以下代碼復制進去

const Koa = require('koa');
const app = new Koa();
const main = ctx => {
    ctx.response.body = 'Hello World';
}
app.use(main);
app.listen(3000);

然后執行以下命令

node app.js

最后在瀏覽器打開http://127.0.0.1:3000/這個連接，如果看到熟悉的“Hello World”就說明你的server已經啟動成功啦。

連接數據庫

這里我是用的是mysql，mac上mysql的安裝可以參考我的這篇mac上n次安裝與卸載mysql。
先安裝nodejs的mysql包

npm install mysql

創建連接:

const Koa = require('koa');
var mysql = require('mysql'); //導入模塊
const app = new Koa();
var connection = mysql.createConnection({
   host:'http://localhost',
   user:'root',
   port: '3306',
   password:'',
   database:'test'
});
connection.connect();  //創建連接

操作數據庫

附上自己創建表的sql語句

create table  record( 
id INT NOT NULL   AUTO_INCREMENT,
userId INT NOT NULL,
text TEXT,
foreign key(userId) references user(id),
PRIMARY KEY(id)
);

create table record_img( 
id  INT NOT NULL   AUTO_INCREMENT,
recordId INT NOT NULL,
imgSrc varchar(255) NOT NULL,
foreign key(recordId) references record(id),
PRIMARY KEY(id)
);

create table user( 
id INT NOT NULL   AUTO_INCREMENT,
nickName varchar(200)  NOT NULL,
gender varchar(200),
city varchar(200),
province  varchar(200),
country  varchar(200),
birthday DATE,
PRIMARY KEY(id)
);

對數據庫的基本操作

• 查詢

var sql ='select * from user';
connection.query(sql,function(err,result){
    if(err){
        console.log('[SELECT ERROR] - ',err.message);
        return;
    }
    console.log('--------------------------SELECT----------------------------');
    console.log(result);
    console.log('------------------------------------------------------------\n\n');

});

• 修改

connection.connect();  //創建連接
var sql ='update user set nickName = ? where id = ?';
var sqlpar=['julieCopy',1];

connection.query(sql,sqlpar,function(err,result){
    if(err){
        console.log('[UPDATE ERROR] - ',err.message);
        return;
    }
    console.log('--------------------------SELECT----------------------------');
    console.log('UPDATE affectedRows',result.affectedRows);
    console.log('------------------------------------------------------------\n\n');

});
connection.end();

• 增加

connection.connect();  //創建連接
var addSql ='insert into  user (nickName) values(?)';
var addPar= ['jessicacopy'];
connection.query(addSql,addPar,function(err,result){
    if(err){
        console.log('[insert ERROR] - ',err.message);
        return;
    }
    console.log('--------------------------SELECT----------------------------');
    console.log('UPDATE affectedRows',result.affectedRows);
    console.log('------------------------------------------------------------\n\n');

});
connection.end();

• 刪除

connection.connect();  //創建連接
var delSql ='delete from  user where id = 2';

connection.query(delSql,function(err,result){
   if(err){
       console.log('[UPDATE ERROR] - ',err.message);
       return;
   }
   console.log('--------------------------SELECT----------------------------');
   console.log('UPDATE affectedRows',result.affectedRows);
   console.log('------------------------------------------------------------\n\n');

});
connection.end();