快捷導(dǎo)航

使用Node操作MySQL的兩種方式

更新時間：2024年05月13日 08:31:18 作者：云牧

本文將介紹如何在?Node.js?應(yīng)用中使用?mysql2?和?TypeORM?兩種方式操作?MySQL?數(shù)據(jù)庫,文中通過代碼示例介紹的非常詳細,對大家的學(xué)習(xí)有一定的幫助,需要的朋友可以參考下

使用 mysql2 庫操作 MySQL

mysql2 是 mysql 庫的升級版，提供了更多特性，并且支持 Promise API。以下是使用 mysql2 進行數(shù)據(jù)庫操作的基本步驟：

安裝和配置

創(chuàng)建項目目錄，初始化 npm，并安裝 mysql2：

mkdir myproject
cd myproject
npm init -y
npm install --save mysql2

創(chuàng)建 index.js 文件，并配置數(shù)據(jù)庫連接：

const mysql = require('mysql2');

const connection = mysql.createConnection({
  host: 'localhost',
  port: 3306,
  user: 'root',
  password: 'your_password',
  database: 'practice'
});

基本操作

查詢操作

connection.query('SELECT * FROM customers', (err, results, fields) => {
  if (err) throw err;
  console.log(results);
  console.log(fields.map(item => item.name));
});

插入數(shù)據(jù)

connection.execute('INSERT INTO customers (name) VALUES (?)', ['Zhang'], (err, results) => {
  if (err) throw err;
  console.log('Insert successful');
});

更新數(shù)據(jù)

connection.execute('UPDATE customers SET name="Li" WHERE name="Zhang"', (err) => {
  if (err) throw err;
  console.log('Update successful');
});

刪除數(shù)據(jù)

connection.execute('DELETE FROM customers WHERE name="Li"', (err) => {
  if (err) throw err;
  console.log('Delete successful');
});

使用連接池提高性能

連接池可以管理多個數(shù)據(jù)庫連接，提高應(yīng)用性能和響應(yīng)速度：

const mysql = require('mysql2/promise');

(async () => {
  const pool = mysql.createPool({
    host: 'localhost',
    user: 'root',
    password: 'your_password',
    database: 'practice',
    waitForConnections: true, // 如果沒有可用連接，等待而不是立即拋出錯誤
    connectionLimit: 10, // 連接池中最大連接數(shù)
    queueLimit: 0 // 最大排隊數(shù)量，0表示不限制
  });

  const [results] = await pool.query('SELECT * FROM customers');
  console.log(results);
})();

使用 TypeORM 框架操作 MySQL

TypeORM 是一個基于 TypeScript 的 ORM (對象關(guān)系映射) 框架，它可以讓開發(fā)者通過操作對象而不是 SQL 語句來處理數(shù)據(jù)庫。

項目設(shè)置

創(chuàng)建并配置新項目：

npx typeorm@latest init --name typeorm-mysql-test --database mysql

在 data-source.ts 中配置數(shù)據(jù)庫：

import { DataSource } from 'typeorm';
import { User } from './entity/User';

export const AppDataSource = new DataSource({
  type: 'mysql',
  host: 'localhost',
  port: 3306,
  username: 'root',
  password: 'your_password',
  database: 'practice',
  synchronize: true,
  entities: [User],
  connectorPackage: 'mysql2'
});

操作數(shù)據(jù)庫

使用裝飾器定義模型（Entity）：

import { Entity, PrimaryGeneratedColumn, Column } from 'typeorm';

@Entity()
export class User {
  @PrimaryGeneratedColumn()
  id: number;

  @Column()
  name: string;
}

插入和查詢數(shù)據(jù)

import { AppDataSource } from './data-source';
import { User } from './entity/User';

AppDataSource.initialize().then(async () => {
  const user = new User();
  user.name = 'Wang';
  await AppDataSource.manager.save(user);

  const users = await AppDataSource.manager.find(User);
  console.log(users);
});