nodejs中mysql的用法

1、建立数据库连接：

createConnection(Object)方法
该方法接受一个对象作为参数，该对象有四个常用的属性host，user，password，database。属性列表如下：

host:　　　　　　 连接数据库所在的主机名. (默认: localhost)
user: 　　　　　　　　MySQL用户的用户名.
password:　　　　 　　MySQL用户的密码.
database: 　　　　　　链接到的数据库名称 (可选).

2.首先在nodejs中安装mysql，并显示在依赖中

npm install mysql

3导入mysql

var mysql = require('mysql');

4与数据库创建链接

var connection=mysql.createConnection({
    host:'localhost',
    user:'root',
    password:'root',
    database:'test'
});
// 与数据库建立连接
connection.connect((err)=>{

    if(err) throw err;

    console.log('连接成功')

})

5.设置跨域问题

app.all("*",function(req,res,next){
	//设置允许跨域的域名，*代表允许任意域名跨域
    res.header("Access-Control-Allow-Origin", "*");
    //允许的header类型
    res.header("Access-Control-Allow-Headers", "content-type");
    //允许的请求类型
    res.header("Access-Control-Allow-Methods", "PUT,POST,GET,DELETE,OPTIONS");
    //请求的响应类型
    res.header("Content-Type", "application/json;charset=utf-8");
    next();
})

6.使用查询方法

//执行SQL语句
connection.query('SELECT * FROM cq', function (error, results, fields) {
  if (error) throw error;
  console.log('The solution is: ', results);
});

7.带参数查询

//执行SQL语句
connection.query('SELECT * FROM cq where id =?',['1'], function (error, results, fields) {
  if (error) throw error;
  console.log('The solution is: ', results);
});

8.添加

//插入数据 insert into 数据表名 （属性名） values(属性值)
 connection.query('insert into cq (name,age,score) values ("李易峰",20,100)', function (error, results, fields) {
	if (error) throw error;
	console.log(results);
});

9.修改

//修改数据
connection.query('update cq set name="小李子",score = 100 where id = 2', (error, results, fields) => {
     if (error) throw error;
    console.log(results);
});

10.删除

//删除 根据某一个id删除数据
connection.query('delete from students where id in (12,15,13)', function (error, results, fields) {
   if (error) throw error;
   console.log(results);
});

11.后面加上

//关闭数据库连接
connection.end();

本文地址：https://blog.csdn.net/qq_45970651/article/details/107648492