简体中文(ZH-CN) English(EN) 繁体中文(ZH-TW)
首頁 > 資料庫 > mysql教程 > 主體

Nodejs中koa2怎麼連接mysql

WBOY
發布： 2023-06-01 12:40:06
轉載
1081 人瀏覽過

將查詢結果轉為物件或陣列

在真實開發中，實際上某些查詢結果應該放入到一個物件中

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;
登入後複製

Nodejs中koa2怎麼連接mysql

在多對多關係中，我們希望查詢到的是一個陣列：

  • 例如一個學生的多門課程訊息，應該是放到一個陣列中的；

  • 陣列中存放的是課程資訊的一個物件；

  • 這時候我們要JSON_ARRAYAGG和JSON_OBJECT結合來使用;

Nodejs中koa2怎麼連接mysql

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的使用

安裝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();
});
登入後複製

Prepared Statement(預處理語句)

提高效能：將建立的語句模組傳送給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 Pools(連接池)

前面我們是創建了一個連接（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);
});
登入後複製

Promise方式

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);
});
登入後複製

sequelize

物件關係映射(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的連接資料庫：

第一步：建立一個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);
});
登入後複製

Sequelize的單表操作

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();//执行这个函数可以实现对数据库的操作
登入後複製

Sequelize的一對多操作

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();
登入後複製

Sequelize的多對多操作

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的詳細內容。更多資訊請關注PHP中文網其他相關文章！

相關標籤：
mysql nodejs koa2
來源：yisu.com
上一篇：MySQL中怎麼使用SQL語句判斷表格是否存在 下一篇：MySQL之排序與單行處理函數怎麼使用
本網站聲明
本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn
作者最新文章
最新問題
如何在 PHP 中使用 while 迴圈按 ID 列出節中的資料？ 我有一個包含這些列的mysql表：series_id,series_color,product_name在輸出中，我想按部分列出數據，每個series_id一個部分，如下所示：A1...
來自於 2023-11-17 20:03:03
0
1
290
MySQL中使用觸發器和約束限制記錄數 我有一個名為BFFs的表，用於儲存用戶ID和最好朋友的用戶ID，我想限制該表為每個不同的用戶提供3個最好的朋友。我的意思是如果表格結構是：BFFs(userID,userID)記錄...
來自於 2023-11-14 13:35:02
0
4
434
解決Django中的django.db.utils.NotSupportedError錯誤 我在Django中運行專案時遇到錯誤。問題是不幸的是我升級了我的pip、MySQL客戶端和Django版本這是運行pythonmanage.pyrunserver時的錯誤inche...
來自於 2023-11-14 11:59:20
0
1
246
檢索具有相同列值的 MySql 行 讓我們考慮下表-IDScore19521003884100573我是一個十足的SQL菜鳥，但是如何返回包含ID2和4的分數？因此它應該返回100，因為它同時出現在ID2和4中
來自於 2023-11-10 21:53:39
0
2
331
在Flutter中如何將SQLite資料庫資料發佈到線上MySQL資料庫？ 如何在Flutter中將離線SQLite同步到MySQL線上資料庫？有什麼建議嗎？
來自於 2023-11-10 12:36:40
0
2
247
相關專題
更多>
熱門推薦
熱門教學
更多>
相關教學
熱門推薦
最新課程
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板
關於我們 免責聲明 Sitemap
PHP中文網：公益線上PHP培訓，幫助PHP學習者快速成長！