mysql#

1const http = require('http');
2//引入mysql模块
3const mysql = require('mysql');
4//配置数据库
5let connection = mysql.createConnection({
6    host:'127.0.0.1',
7    user:'root',
8    password:'rootroot',
9    database:'数据库名'
10})
11//连接数据库
12connection.connect()
13
14let server = http.createServer((req,res)=>{
15    let url = req.url;
16    if(url == '/路径' && req.method == 'GET'){
17        let sql = 'sql语句';
18        connection.query(sql,(error,results)=>{
19            //query(参数1,参数2)
20            //参数1:sql语句
21            //参数2:回调函数 ==> error错误信息，results返回结果
22            if(!error){
23                console.log(results);
24                res.end()            
25            }        
26        })    
27    }
28})
29
30server.listen(8090)

1const http = require('http');
2//引入mysql模块
3const mysql = require('mysql');
4//配置数据库
5let connection = mysql.createConnection({
6    host:'127.0.0.1',
7    user:'root',
8    password:'rootroot',
9    database:'数据库名'
10})
11//连接数据库
12connection.connect()
13
14let server = http.createServer((req,res)=>{
15    let url = req.url;
16    if(url == '/路径' && req.method == 'GET'){
17        //准备sql
18        let sql = 'select * from sql where id = ?';
19        //绑定值【必须是数组!!!】
20        let val = [10];
21        //返回预处理
22        let newSql = mysql.format(sql,val);
23        
24        connection.query(newSql,(error,results)=>{
25            if(!error){
26                ////affectedRows: 1, 受影响行数
27                console.log(results);
28                res.end()            
29            }        
30        })    
31    }
32})
33
34server.listen(8090)