简介
MySQL是一个关系型数据库管理系统,由瑞典MySQL AB公司开发,属于Oracle旗下产品。MySQL是最流行的关系型数据库管理系统之一,在WEB应用方面,MySQL是最好的RDBMS(Relational Database Management System,关系型数据库管理系统)应用软件之一。
MySQL是一种关系型数据库管理系统,关系数据库将数据保存在不同的表中,而不是将所有数据放在一个大仓库内,这样就增加了速度并提高了灵活性。
MySQL所使用的SQL语言是用于访问数据的最常用标准化语言。MySQL软件采用了双授权政策,分为社区版和商业版,由于其体积小、速度快、总体拥有成本低,尤其是开源代码这一特点,一般中小型和大型网站的开发都选择MySQL作为网站数据库。
使用
第一步:安装mysql2
yarn add mysql2
第二步:写连接数据库的配置文件
db.config.js
// 引入mysql
const mysql = require('mysql2');// 创建连接
const connection = mysql.createConnection({host: 'localhost', // 数据库地址user: 'root', // 用户名password: '123456', // 密码
})// 连接数据库
connection.connect(err => {if (err) {console.error('连接数据库发生错误: ' + err.stack);return;}// 检查并创建数据库const dbName = 'ffmpeg'// 查询ffmepg数据库是否存在,如果不存在则创建connection.query(`CREATE DATABASE IF NOT EXISTS ${dbName}`, (err, result) => {if (err) {console.error('创建数据库失败: ' + err.message);return;}console.log(`数据库${dbName}已存在或已创建`);// 选择数据库connection.changeUser({ database: dbName }, (err) => {if (err) {console.error('选择数据库失败: ' + err.stack);return}})});
})module.exports = connection
第三步:在nodejs的app.js文件中引入并使用db.config.js文件
var createError = require('http-errors');
var express = require('express');
var path = require('path');
var cookieParser = require('cookie-parser');
var logger = require('morgan');var indexRouter = require('./routes/index');var app = express();
// 连接数据库
require('./config/db.config')
// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'jade');app.use(logger('dev'));
app.use(express.json());
app.use(express.urlencoded({ extended: false }));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));// 使用cors解决跨域问题
app.use(require('cors')());app.use('/', indexRouter);// catch 404 and forward to error handler
app.use(function (req, res, next) {next(createError(404));
});// error handler
app.use(function (err, req, res, next) {// set locals, only providing error in developmentres.locals.message = err.message;res.locals.error = req.app.get('env') === 'development' ? err : {};// render the error pageres.status(err.status || 500);res.render('error');
});module.exports = app;
通过以上步骤就可以连接对应的数据库。
如果想要在连接数据的时候顺便创建表,可以按照下方步骤进行
第一步:为了方便管理,我将创建表的逻辑代码单独写成一个js文件 --- GroupModel.js
说明:
创建表格的时候要判断该表是否已经存在,因为重复创建同一个表的时候会报错,所以下方代码使用 CREATE TABLE IF NOT EXISTS 来规避这个问题。
// 引入mysql
const mysql = require('mysql2');// 创建视频分组表
function createGroupTable(connection) {/*AUTO_INCREMENT 定义列为自增主键。*/const sql = `CREATE TABLE IF NOT EXISTS block (id INT AUTO_INCREMENT PRIMARY KEY COMMENT '自增主键',group_name VARCHAR(255) NOT NULL COMMENT '文件名',num INT NOT NULL DEFAULT 0 COMMENT '关联视频数量,默认值为0',create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '上传时间')`;// 执行SQL语句connection.query(sql, (err, result) => {if (err) {console.error('分组表创建失败:', err.message);return;}console.log('分组表已存在或创建');});
}module.exports = createGroupTable
第二步:将GroupModel.js文件在db.config.js文件中引入并使用
// 引入mysql
const mysql = require('mysql2');
const createGroupTable = require('../model/GroupModel');// 创建连接
const connection = mysql.createConnection({host: 'localhost', // 数据库地址user: 'root', // 用户名password: '123456', // 密码
})// 连接数据库
connection.connect(err => {if (err) {console.error('连接数据库发生错误: ' + err.stack);return;}// 检查并创建数据库const dbName = 'ffmpeg'// 查询ffmepg数据库是否存在,如果不存在则创建connection.query(`CREATE DATABASE IF NOT EXISTS ${dbName}`, (err, result) => {if (err) {console.error('创建数据库失败: ' + err.message);return;}console.log(`数据库${dbName}已存在或已创建`);// 选择数据库connection.changeUser({ database: dbName }, (err) => {if (err) {console.error('选择数据库失败: ' + err.stack);return}createGroupTable(connection)})});
})module.exports = connection