Node操作Mysql

npm i mysql 

const mysql = require('mysql')

let connectObj = mysql.createConnection({
                host:'主机名',
                user:'用户名',
                password:'密码'
                port:'端口号',
                database:'要操作哪个数据库'
            })

使用query方法执行sql语句

connectObj.query(sqlStr,(err,results)=>{  })

nodejs通过msyql包操作mysql数据库的步骤：

第一步：引入mysql包

第二步:创建mysql连接：mysql.createConnection();

第三步：开始连接mysql: mysqlObj.connect();

第四步：执行sql语句：mysqlObj.query('sql语句'[,参数值],回调方法);

nodejs通过msyql包操作mysql数据库的代码实例1：

//第一步：引入mysql包
const mysql = require('mysql');
// console.log(mysql);
​
//第二步:创建mysql连接：mysql.createConnection();
const mysqlObj = mysql.createConnection({ host: 'localhost', port: 3306, user: 'root', password: 'root', database: 'mydemo' });
// console.log(mysqlObj);
​
//第三步：开始连接mysql: mysqlObj.connect();
mysqlObj.connect();
​
//第四步：执行sql语句：mysqlObj.query('sql语句'[,参数值],回调方法);
// let sql = `insert into class(banji,teacher)values('go语言开发','张老师')`;
// let sql = `select * from xsb where szx='计算机系'`;
// let sql = `select * from xsb where szx=?`;
let sql = `insert into class(banji,teacher)values(?,?)`;
​
// let val = '数学系';
// let val = '信息系';
​
let val = 'web开发3班';
let teachers = '张老师';
mysqlObj.query(sql, [val, teachers], (err, data) => {
    console.log(err, data);
    // for (let obj of data) {
    //     console.log(`姓名：${obj.xm} 年龄:${obj.age}  所在系：${obj.szx}`);
    // }
});

nodejs通过msyql包操作mysql数据库的代码实例2：

const express = require('express');
const path = require('path');
const mysql = require('mysql');
​
const app = express();
​
app.listen(3000, () => {
    console.log('3000端口');
});
​
//第二步:创建mysql连接：mysql.createConnection();
const mysqlObj = mysql.createConnection({ host: 'localhost', port: 3306, user: 'root', password: 'root', database: 'mydemo' });
// console.log(mysqlObj);
​
//第三步：开始连接mysql: mysqlObj.connect();
mysqlObj.connect();
​
app.use(express.urlencoded({ extended: false }));
//设置ejs:
app.set('view engine', 'ejs'); //设置模板引擎为ejs
app.set('views', [`${path.join(__dirname,'moban')}`]); //设置模板文件的存放位置
app.engine('html', require('ejs').__express); //将html文件作为ejs模板文件来解析
​
​
//显示搜索界面：
app.get('/', (req, res) => {
​
​
    res.render('find.html');
});
​
//处理查询学生：
app.post('/', (req, res) => {
​
    //接参(用户输入的要查询姓名)
    let { usr = '' } = req.body;
    if (usr == '') {
        res.send(``);
        return;
    }
​
    let sql = `select * from xsb where xm like '%${usr}%'`;
    let str = '';
    mysqlObj.query(sql, (err, data) => {
​
        for (let obj of data) {
            str += `姓名：${obj.xm} 年龄:${obj.age}`;
        }
​
​
        res.send(str);
    });
});

find.html文件代码如下：

​

    
    
    
    

​

    

         
        搜索
    

​