📖node.js对数据库进行增删改查操作（增删表）

前言

当前数据库我使用的是 php study 进行本地搭建的一个数据库，如果你的数据库已经创建完成我需要你将我的sql导入到你的数据库中，SQL 文件(下载)

由于网上很多安装node.js的教程，我这里就不写如何安装node.js了

数据库具体的数据如下：

查询指定表中数据

//引入mysql
var mysql  = require('mysql');  

//数据库链接开始 ————————>
var Search_sql = mysql.createConnection({     
  host     : 'localhost',    
  //用户名
  user     : 'Nodesql',   
  //服务器密码           
  password : 'Nodesql',    
  //服务器接口
  port: '3306',
  //数据库名
  database: 'Nodesql'
});
//数据库链接完毕 ————————>

//查询开始 ————————>
Search_sql.connect();
var  sql = 'SELECT * FROM websites';
Search_sql.query(sql,function (err, result) {
        if(err){
          //打印出返回的错误数据
          console.log('[SELECT ERROR] - ',err.message);
          return;
        }
 
       console.log('--------------------------SELECT----------------------------');
       console.log(result);
       console.log('------------------------------------------------------------\n\n');  
});
 
//表示数据获取结束
Search_sql.end();
//查询结束 ————————>

增加表中数据

var mysql  = require('mysql');  
//数据库链接开始 ————————>
var Add_sql = mysql.createConnection({host:'localhost',user: 'Nodesql',password:'Nodesql',port:'3306',database:'Nodesql'});
//数据库链接完毕 ————————>


//增加内容开始 ————————>
Add_sql.connect();
//获取表中的字段
var addSql = 'INSERT INTO websites(id,name,url,alexa,country) Value(0,?,?,?,?)';
//需要插入的数据
var addSqlAry = ['伍言博客','https://wuyanboke.cn','60','CN'];

Add_sql.query(addSql,addSqlAry,function(err,result){
  if(err){
    console.log("链接错误：" + err);
  }
  console.log(result);
})
Add_sql.end();
//增加内容结束 ————————>

修改表中数据

var mysql  = require('mysql');  
//数据库链接开始 ————————>
var Update_sql = mysql.createConnection({host:'localhost',user: 'Nodesql',password:'Nodesql',port:'3306',database:'Nodesql'});
//数据库链接完毕 ————————>

//修改内容开始 ————————>
Update_sql.connect();
var updateSql = 'UPDATE websites SET name = ?,url = ?,alexa = ? WHERE id = ?'
var updateSqlAry = ['伍言笔记','https://www.wuyanboke.cn','1',6];

Update_sql.query(updateSql,updateSqlAry,function(err,result){
	if(err){
		console.log('错误为：'+err)
	}
	console.log(result);
})
Update_sql.end();
//修改内容结束 ————————>

删除表中指定数据

var mysql  = require('mysql');  
//数据库链接开始 ————————>
var Delete_sql = mysql.createConnection({host:'localhost',user: 'Nodesql',password:'Nodesql',port:'3306',database:'Nodesql'});
//数据库链接完毕 ————————>


//删除内容开始 ————————>
Delete_sql.connect();
var DeleteSql = 'DELETE FROM websites WHERE id=6';

Delete_sql.query(DeleteSql,function(err,result){
	if(err){
		console.log('删除错误：'+ err );
	}
	console.log(result);
})
Delete_sql.end();
//删除内容结束 ————————>

创建带有主键的表

var mysql  = require('mysql');  
//数据库链接开始 ————————>
var Create_sql = mysql.createConnection({host:'localhost',user: 'Nodesql',password:'Nodesql',port:'3306',database:'Nodesql'});
//数据库链接完毕 ————————>

//增加表开始 ————————>
Create_sql.connect();
//创建表名为: product(商品)，其中包含:id,name,price,number
var createTab = 'Create TABLE product (id INT PRIMARY KEY, name VARCHAR(255), price INT(10),number INT(50))';

Create_sql.query(createTab,function(err,result){
	if(err){
		console.log('创建表失败：'+err);
	}
	console.log(result);
});

Create_sql.end();

//增加表结束 ————————>

删除数据库中指定表

var mysql  = require('mysql');  
//数据库链接开始 ————————>
var Delete_tab = mysql.createConnection({host:'localhost',user: 'Nodesql',password:'Nodesql',port:'3306',database:'Nodesql'});
//数据库链接完毕 ————————>

//删除数据表开始 ————————>
Delete_tab.connect();

var deleteTab = 'DROP TABLE product';

Delete_tab.query(deleteTab,function(err,result){
	if(err){
		console.log('删除表错误：'+err);
	}
	console.log(result);

})

Delete_tab.end();

//删除数据表结束 ————————>