一. 安装mysql
npm install mysql --save
二. mysql的连接
const mysql = require('mysql')
var connection = mysql.createConnection({
host: "127.0.0.1",
port: 3306,
user: 'root',
password: 'root',
database: 'db1'
timezone: '08:00'
});
connection.connect();
将来大家实际用的时候, 很可能遇到node 和mysql 时区不统一的问题, 所以这里加了个设置东八区的参数
三. DDL操作：数据库操作
1. 创建数据库
//创建数据库
var CREATE_DB = (dbName) => `CREATE DATABASE IF NOT EXISTS ${dbName};`;
connection.query(CREATE_DB("db4"), (error, results) => {
if (error) throw error;
console.log(results);
});
2. 查询所有数据库
const mysql = require('mysql')
var connection = mysql.createConnection({
host: "127.0.0.1",
port: 3306,
user: 'root',
password: 'root',
database: 'db1'
timezone: '08:00'
});
connection.connect();
// 显示所有数据库
connection.query('show databases', (error, results) => {
if (error) throw error;
console.log(results);
});
运行结果
3. 删除数据库
//删除数据库
var DELETE_DB = (dbName) => `DROP DATABASE IF EXISTS ${dbName};`;
connection.query(CREATE_DB("db4"), (error, results) => {
if (error) throw error;
console.log(results);
});
4. 查询正在使用的数据库
//查询当前正在使用的数据库
connection.query("select database();", (error, results) => {
if (error) throw error;
console.log(results);
});
结果:
5. 使用数据库
//使用的数据库
var USE_DB = (dbName) =>
`USE ${dbName};`;
connection.query(USE_DB("db1"), (error, results) => {
if (error) throw error;
console.log(results);
});
四. DDL操作：数据表操作
1. 查询所有数据表
// 查询表
connection.query('show tables;', (error, results) => {
if (error) throw error;
console.log(results);
});
2. 添加数据表
// 添加表
var CREATE_TABLE = (tableName) => `CREATE TABLE IF NOT EXISTS ${tableName} (id int NOT NULL primary key AUTO_INCREMENT comment 'primary key',created_time TIMESTAMP COMMENT 'created tiem',updated_time TIMESTAMP COMMENT 'updated tiem')`;
connection.query(CREATE_TABLE("boys"), (error, results) => {
if (error) throw error;
console.log(results);
});
返回结果和我们创建表时的提示信息是一样的
3. 删除表
这里我用了一个闭包写法,实际使用时请灵活决策用不用
//删除表
((tableName) => {
var DROP_TABLE = (tableName) => `DROP TABLE IF EXISTS ${tableName};`;
connection.query(DROP_COLUM(tableName), (error, results) => {
if (error) return console.log("not need to drop");
console.log(results);
});
})("boys");
4. 添加字段
添加字段之前, 我们要判断字段是否存在,如果存在就把它删除掉.
这里我用了一个闭包写法,实际使用时请灵活决策用不用
//添加表的字段
((tableName, column_name, column_type) => {
var ADD_COLUM = (tableName, column_name, column_type) => `ALTER TABLE ${tableName} ADD ${column_name} ${column_type};`;
var DROP_COLUM = (tableName, column_name) => `ALTER TABLE ${tableName} DROP ${column_name};`;
connection.query(DROP_COLUM(tableName, column_name), (error, results) => {
if (error) return console.log("not need to drop");
console.log(results);
});
connection.query(ADD_COLUM(tableName, column_name, column_type), (error, results) => {
if (error) throw error;
console.log(results);
});
})("boys", "music", "INT");
五. 数据操作 (DML)
1. 查询数据
// 查询条目
var QUERY_DATAS = (tableName) => `SELECT * FROM ${tableName};`;
connection.query(QUERY_DATAS("student"), (error, results) => {
if (error) throw error;
console.log("总共有:%d条数据",results.length);
console.log(results);
console.log("摘取第一条看一看");
console.log(results[0]);
console.log(results[0].id);
console.log(results[0].name);
console.log(results[0].age);
console.log(results[0].brithday);
});
2. 插入数据(全部列)
//添加数据
var INSERT_DATAS = (tableName,values) => `INSERT INTO ${tableName} VALUES (${values});`;
connection.query(INSERT_DATAS("student",'2,"貂蝉",24,99,now(),now()'), (error, results) => {
if (error) throw error;
console.log(results);
});
3. 插入数据(部分列)
//添加数据
var INSERT_DATAS = (tableName,colums,values) => `INSERT INTO ${tableName}(${colums}) VALUES (${values});`;
connection.query(INSERT_DATAS("student",'name,age,score','"王昭君",27,99.5'), (error, results) => {
if (error) throw error;
console.log(results);
});
4. 删除数据
//删除数据条目
var DELETE_DATAS_BY_ID = (tableName, id) =>
`DELETE FROM ${tableName} WHERE (id = ${id});`;
connection.query(DELETE_DATAS_BY_ID("student", 3), (error, results) => {
if (error) throw error;
console.log(results);
});
5. 删除所有数据
//删除数据条目
var DELETE_DATAS = (tableName) =>
`DELETE FROM ${tableName};`;
connection.query(DELETE_DATAS("student"), (error, results) => {
if (error) throw error;
console.log(results);
});
6. 更新数据条目
//更新数据
var UPDATE_DATA = (tableName,id,colum,value) =>
`UPDATE ${tableName} SET ${colum} = ${value} WHERE id = ${id};`;
connection.query(UPDATE_DATA("student",2,'age',27), (error, results) => {
if (error) throw error;
console.log(results);
});
六、DQL 查询语句
现在大家基本看明白了, 以上功能都只是用了不同的sql语句而已
实际运用中,我们可能只会用到一小部分语句
至于查询语句, 实在太灵活了, 真的没法枚举了, 只举一个例子
//查询数据
connection.query("select id,name from student where age>10 and age <30;", (error, results) => {
if (error) throw error;
console.log(results);
});
结果返回一个列表:
七. 约束, 外键
其实还是一样的执行sql语句,但这些使用程序来做好像麻烦了,干脆用workbench远程连接数据库来做
八. 连接池
在开发web应用程序时，连接池是一个很重要的概念。建立一个数据库连接所消耗的性能成本是很高的。在服务器应用程序中，如果为每一个接收到的客户端请求都建立一个或多个数据库连接，将严重降低应用程序性能。
因此在服务器应用程序中通常需要为多个数据库连接创建并维护一个连接池，当连接不再需要时，这些连接可以缓存在连接池中，当接收到下一个客户端请求时，从连接池中取出连接并重新利用，而不需要再重新建立连接。
1. 语法：
（1）创建连接池 createPool
var pool = mysql.createPool(optioins);
options参数包含createConnection方法中可以使用的各种属性，除此之外还有以下属性：createConnection，waitForConnections，connectionLimit，queueLimit。
（2）获取连接 pool.getConnection
从连接池中取出连接。getConnection方法。如无连接可用则隐式的建立一个数据库连接。
pool.getConnection(function(err,connection));
回调函数中的err为错误对象，connection为获取到的连接对象。
（3）归还连接池 connection.release();
当连接不再使用时，用connection对象的release方法将其归还到连接池中。
connection.release();
（4）销毁连接 connection.destroy();
当一个连接不再需要使用且需要从连接池中移除时，用connection对象的destroy方法。
connection.destroy();
连接移除后，连接池中的连接数减一。
（5）关闭连接池 pool.end();
当一个连接池不再需要使用时，用连接池对象的end方法关闭连接池。
pool.end();
2. 连接示例
const mysql = require("mysql");
var pool = mysql.createPool({
host: "127.0.0.1",
port: 3306,
user: "root",
password: "xxxxxxxxxxxxx",
database: "db1",
timezone: '08:00'
});
pool.getConnection(function (err, connection) {
if (err) throw err;
connection.query(
"select id,name from student where age>10 and age <30;",
(error, results) => {
if (error) throw error;
console.log(results);
connection.release();
}
);
});
接下来, 我们将使用KOA2来操作MySQL, 详见下一篇文章.
网友评论