安装Mysql模块
npm install mysql
注：由于不是全局安装，建议下面的文件也放在模块的同级目录中去
连接Mysql数据库
const mysql
= require('mysql');
let connection
= mysql
.createConnection(
{
host
: 'localhost',
user
: 'root',
password
:'123456',
port
: '3306',
database
: 'test'
}
);
connection
.connect((err
, result
) => {
if (err
) {
console
.log(err
);
console
.log("连接失败");
return;
}
console
.log(result
);
console
.log("连接成功");
});
connection
.end();
查询数据
et sql
= 'select * from users_copy1';
connection
.query(sql
,(err
,result
)=> {
if (err
) {
console
.log('[SELECT 失败] - ', err
.message
);
return;
}
console
.log('--------------查询-------------');
console
.log('查询成功:',result
);
console
.log('--------------------------\n\n');
});
connection
.end();
插入数据
let Sql
= 'INSERT INTO users_copy1(id,name,age,pwd,user_sex,info) VALUES(0,?,?,?,?,?)';
let SqlParams
= ['东契奇', '21', '77','Man','player'];
connection
.query(Sql
, SqlParams
, (err
, result
) => {
if (err
) {
console
.log('[增加失败] - ', err
.message
);
return;
}
console
.log('---------------插入-------------');
console
.log('增加成功 ID:',result
.insertId
);
console
.log('增加成功:', result
);
console
.log('--------------------------------\n\n');
});
connection
.end();
更新数据
let upSql
= 'UPDATE users_copy1 SET name = ? WHERE id = ?';
let upSqlParams
= ['卢卡', 0];
connection
.query(upSql
, upSqlParams
, (err
, result
) => {
if (err
) {
console
.log('[更新失败] - ', err
.message
);
return;
}
console
.log('------------更新---------------');
console
.log('更新成功', result
.affectedRows
);
console
.log('-------------------------------\n\n');
});
connection
.end();
删除数据
let delSql
= 'DELETE FROM users_copy1 where id=0';
connection
.query(delSql
, (err
, result
) => {
if (err
) {
console
.log('[删除失败] - ', err
.message
);
return;
}
console
.log('---------删除------------');
console
.log('删除成功', result
.affectedRows
);
console
.log('------------------------\n\n');
});
connection
.end();
注意：五部分代码放在一个js文件即可使用，至于数据库sql可以参照插入的自己编一个
