溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
本文小編為大家詳細介紹“Nodejs中koa2怎么連接mysql”，內容詳細，步驟清晰，細節處理妥當，希望這篇“Nodejs中koa2怎么連接mysql”文章能幫助大家解決疑惑，下面跟著小編的思路慢慢深入，一起來學習新知識吧。
在真實開發中，實際上某些查詢結果應該放入到一個對象中
JSON_OBJECT：（）中是key-value的形式
SELECT products.id as id, products.title as title, products.price as price, products.score as score,
JSON_OBJECT('id', brand.id, 'name', brand.name, 'rank', brand.phoneRank, 'website', brand.website) as brand
FROM products LEFT JOIN brand ON products.brand_id = brand.id;
在多對多關系中，我們希望查詢到的是一個數組：
比如一個學生的多門課程信息，應該是放到一個數組中的；
數組中存放的是課程信息的一個個對象；
這個時候我們要JSON_ARRAYAGG和JSON_OBJECT結合來使用；
SELECT stu.id, stu.name, stu.age,
JSON_ARRAYAGG(JSON_OBJECT('id', cs.id, 'name', cs.name)) as courses
FROM students stu
LEFT JOIN students_select_courses ssc ON stu.id = ssc.student_id
LEFT JOIN courses cs ON ssc.course_id = cs.id
GROUP BY stu.id;安裝mysql2:
npm install mysql2
簡單使用：
const mysql = require('mysql2');
// 1.創建數據庫連接
const connection = mysql.createConnection({
host: 'localhost',
port: 3306,
database: 'coderhub',
user: 'root',
password: 'Coderwhy888.'
});
// 2.執行SQL語句
const statement = `
SELECT * FROM products WHERE price > 6000;
`
connection.query(statement, (err, results, fields) => {
console.log(results);
});如果我們想要在拿到數據后停止服務，可以在回調函數中寫上：
connection.end()
完整代碼：
connection.query(statement, (err, results, fields) => {
console.log(results);
connection.end();
});提高性能：將創建的語句模塊發送給MySQL，然后MySQL編譯（解析、優化、轉換）語句模塊，并且存儲
它但是不執行，之后我們在真正執行時會給?提供實際的參數才會執行；就算多次執行，也只會編譯一次，所以性能是更高的；
強調：如果再次執行該語句，它將會從LRU（Least Recently Used） Cache中獲取獲取，省略了編譯statement的時間來提高性能。
// 2.執行SQL語句: 使用 ？來對參數進行占位
const statement = `
SELECT * FROM products WHERE price > ? AND score > ?;
`
connection.execute(statement, [6000, 7], (err, results) => {
console.log(results);
});前面我們是創建了一個連接（connection），但是如果我們有多個請求的話，該連接很有可能正在被占用，那么我們是否需要每次一個請求都去創建一個新的連接呢？
事實上，mysql2給我們提供了連接池（connection pools）；
連接池可以在需要的時候自動創建連接，并且創建的連接不會被銷毀，會放到連接池中，后續可以繼續使用；
我們可以在創建連接池的時候設置LIMIT，也就是最大創建個數；
判斷是否連接成功
const mysql = require('mysql2');
// 1.創建連接池
const connections = mysql.createPool({
host: 'localhost',
port: 3306,
database: 'coderhub',
user: 'root',
password: 'Coderwhy888.',
connectionLimit: 10
});
connections.getConnection((err, conn) => {
conn.connect((err) => {
if(err){
console.log('連接失敗：',err)
} else {
console.log('數據庫連接成功~')
}
})
})簡單使用數據庫
const mysql = require('mysql2');
// 1.創建連接池
const connections = mysql.createPool({
host: 'localhost',
port: 3306,
database: 'coderhub',
user: 'root',
password: 'Coderwhy888.',
connectionLimit: 10
});
// 2.使用連接池
const statement = `
SELECT * FROM products WHERE price > ? AND score > ?;
`
connections.execute(statement, [6000, 7], (err, results) => {
console.log(results);
});const mysql = require('mysql2');
// 1.創建連接池
const connections = mysql.createPool({
host: 'localhost',
port: 3306,
database: 'coderhub',
user: 'root',
password: 'Coderwhy888.',
connectionLimit: 10
});
// 2.使用連接池
const statement = `
SELECT * FROM products WHERE price > ? AND score > ?;
`
connections.promise().execute(statement, [6000, 7]).then(([results,fields]) => {
console.log(results);
}).catch(err => {
console.log(err);
});對象關系映射(ORM):是一種程序設計的方案：
從效果上來講，它提供了一個可在編程語言中，使用虛擬對象數據庫的效果；
Node當中的ORM我們通常使用的是sequelize;
Sequelize是用于Postgres，MySQL，MariaDB，SQLite和Microsoft SQL Server的基于Node.js 的ORM；
它支持非常多的功能；
如果我們希望將Sequelize和MySQL一起使用，那么我們需要先安裝兩個東西：
mysql2：sequelize在操作mysql時使用的是mysql2；
sequelize：使用它來讓對象映射到表中；
npm install sequelize mysql2
Sequelize的連接數據庫：
第一步：創建一個Sequelize的對象，并且指定數據庫、用戶名、密碼、數據庫類型、主機地址等；
第二步：測試連接是否成功；
const { Sequelize } = require('sequelize');
const sequelize = new Sequelize('coderhub', 'root', 'Coderwhy888.', {
host: 'localhost',
dialect: 'mysql'//連接的數據庫類型：mysql，mongoose
});
sequelize.authenticate().then(() => {
console.log("連接數據庫成功~");
}).catch(err => {
console.log("連接數據庫失敗~", err);
});const { Sequelize, DataTypes, Model, Op } = require('sequelize');
const sequelize = new Sequelize("coderhub", 'root', 'Coderwhy888.', {
host: 'localhost',
dialect: 'mysql'
})
//1.首先我們需要將數據庫中的一張表映射成一個class類
class Product extends Model {}
Product.init({
id: {
type: DataTypes.INTEGER,
primaryKey: true,//主鍵
autoIncrement: true//自動增長
},
title: {
type: DataTypes.STRING,
allowNotNull: false//是否可以為空
},
price: DataTypes.DOUBLE,
score: DataTypes.DOUBLE
}, {//與數據庫的表進行映射的配置
tableName: 'products',
createdAt: false,
updatedAt: false,
sequelize
});
//存放操作數據庫的代碼
async function queryProducts() {
//1.查詢數據庫中product表中所有的內容
const result1 = await Product.findAll({
where: {//在這里配置條件
price: {
[Op.gte]: 5000//意思是價格大于等于5000
//gte:大于等于，gt:大于，lt:小于，lte:小于等于
}
}
});
console.log(result1);
// 2.插入數據
const result2 = await Product.create({
title: "三星Nova",
price: 8888,
score: 5.5
});
console.log(result2);
// 3.更新數據
const result3 = await Product.update({
price: 3688
}, {
where: {
id: 1
}
});
console.log(result3);
}
queryProducts();//執行這個函數可以實現對數據庫的操作const { Sequelize, DataTypes, Model, Op } = require('sequelize');
const sequelize = new Sequelize("coderhub", 'root', 'Coderwhy888.', {
host: 'localhost',
dialect: 'mysql'
});
//數據庫的第一個表: 主表
class Brand extends Model {};
Brand.init({
id: {
type: DataTypes.INTEGER,
primaryKey: true,
autoIncrement: true
},
name: {
type: DataTypes.STRING,
allowNotNull: false
},
website: DataTypes.STRING,
phoneRank: DataTypes.INTEGER
}, {
tableName: 'brand',
createdAt: false,
updatedAt: false,
sequelize
});
//數據庫的第二個表：附表
class Product extends Model {}
Product.init({
id: {
type: DataTypes.INTEGER,
primaryKey: true,
autoIncrement: true
},
title: {
type: DataTypes.STRING,
allowNotNull: false
},
price: DataTypes.DOUBLE,
score: DataTypes.DOUBLE,
brandId: {
field: 'brand_id',
type: DataTypes.INTEGER,
references: {//這張表使用了Brand的id作為外鍵
model: Brand,//product這張表使用了Brand這個表，所以product必須放在下面
key: 'id'
}
}
}, {
tableName: 'products',
createdAt: false,
updatedAt: false,
sequelize
});
// 將兩張表聯系在一起
Product.belongsTo(Brand, {
foreignKey: 'brandId'//外鍵
});
async function queryProducts() {
const result = await Product.findAll({
include: { //這里是聯合查詢：意思是包含別的表的信息
model: Brand
}
});
console.log(result);
}
queryProducts();const { Sequelize, DataTypes, Model, Op } = require('sequelize');
const sequelize = new Sequelize("coderhub", 'root', 'Coderwhy888.', {
host: 'localhost',
dialect: 'mysql'
});
// Student表
class Student extends Model {}
Student.init({
id: {
type: DataTypes.INTEGER,
primaryKey: true,
autoIncrement: true
},
name: {
type: DataTypes.STRING,
allowNotNull: false
},
age: DataTypes.INTEGER
}, {
tableName: 'students',
createdAt: false,
updatedAt: false,
sequelize
});
// Course表
class Course extends Model {}
Course.init({
id: {
type: DataTypes.INTEGER,
primaryKey: true,
autoIncrement: true
},
name: {
type: DataTypes.STRING,
allowNotNull: false
},
price: DataTypes.DOUBLE
}, {
tableName: 'courses',
createdAt: false,
updatedAt: false,
sequelize
});
// StudentCourse表：關系表
class StudentCourse extends Model {}
StudentCourse.init({
id: {
type: DataTypes.INTEGER,
primaryKey: true,
autoIncrement: true
},
studentId: {//與Student表建立關系
type: DataTypes.INTEGER,
references: {
model: Student,
key: 'id'
},
field: 'student_id'
},
courseId: {//與Course表建立關系
type: DataTypes.INTEGER,
references: {
model: Course,
key: 'id'
},
field: 'course_id'
}
}, {
tableName: 'students_select_courses',
createdAt: false,
updatedAt: false,
sequelize
});
// 多對多關系的聯系：Student StudentCourse Course
Student.belongsToMany(Course, {
through: StudentCourse,
foreignKey: 'studentId',//這里是Student與StudentCourse，所以外鍵是studentId
otherKey: 'courseId'//StudentCourse與Course，所以外鍵是courseId
});
//與上面類似
Course.belongsToMany(Student, {
through: StudentCourse,
foreignKey: 'courseId',
otherKey: 'studentId'
});
async function queryProducts() {
const result = await Student.findAll({
include: {//所有學生的選課情況
model: Course
}
});
console.log(result);
}
queryProducts();讀到這里，這篇“Nodejs中koa2怎么連接mysql”文章已經介紹完畢，想要掌握這篇文章的知識點還需要大家自己動手實踐使用過才能領會，如果想了解更多相關內容的文章，歡迎關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
