💓 博客主页：瑕疵的CSDN主页
📝 Gitee主页：瑕疵的gitee主页
⏩ 文章专栏：《热点资讯》
TypeORM在Node.js中的高级应用
- TypeORM在Node.js中的高级应用
- 引言
- TypeORM 基本概念
- 1. 实体（Entity）
- 2. 数据库连接
- 3. 查询构建器
- 4. 事务处理
- 5. 迁移管理
- 连接配置
- 1. 使用 JSON 对象配置
- 2. 使用环境变量配置
- 实体定义
- 1. 基本实体
- 2. 关联实体
- 查询构建
- 1. 基本查询
- 2. 复杂查询
- 事务处理
- 1. 基本事务
- 2. 回滚事务
- 迁移管理
- 1. 创建迁移文件
- 2. 编写迁移文件
- 3. 运行迁移
- 4. 回滚迁移
- 最佳实践
- 1. 使用环境变量
- 2. 代码复用
- 3. 事务处理
- 4. 迁移管理
- 5. 日志记录
- 实际案例
- 1. 博客系统
- 2. 电商系统
- 未来展望
- 1. 技术创新
- 2. 社区支持
- 3. 普及应用
- 结论
- 参考文献
- 代码示例
- 定义实体
- 连接数据库
- 执行查询
TypeORM 是一个非常强大的 ORM（对象关系映射）库，适用于 TypeScript 和 JavaScript 的 Node.js 应用程序。它支持多种数据库，如 MySQL、PostgreSQL、SQLite、Mssql 等，并提供了丰富的功能来简化数据库操作。本文将详细介绍 TypeORM 在 Node.js 中的高级应用，包括连接配置、实体定义、查询构建、事务处理、迁移管理等方面。
实体是 TypeORM 中的基本单元，表示数据库表中的记录。通过定义实体类，可以方便地进行数据库操作。
TypeORM 使用连接配置来建立与数据库的连接。连接配置可以是 JSON 对象或环境变量。
TypeORM 提供了强大的查询构建器，可以方便地构建复杂的 SQL 查询。
事务处理确保了一组数据库操作的原子性，即要么全部成功，要么全部失败。
迁移管理允许你通过代码来管理数据库结构的变化，确保数据库模式与应用程序保持同步。
import { createConnection } from 'typeorm';
createConnection({
type: 'mysql',
host: 'localhost',
port: 3306,
username: 'test',
password: 'test',
database: 'test',
entities: [
__dirname + '/entity/**/*.ts' // 指定实体文件路径
],
synchronize: true, // 自动同步数据库结构
logging: false, // 是否开启日志
}).then(connection => {
console.log('Connected to database!');
}).catch(error => console.log(error));
import { createConnection } from 'typeorm';
import * as dotenv from 'dotenv';
dotenv.config();
createConnection({
type: 'mysql',
host: process.env.DB_HOST,
port: parseInt(process.env.DB_PORT),
username: process.env.DB_USERNAME,
password: process.env.DB_PASSWORD,
database: process.env.DB_DATABASE,
entities: [
__dirname + '/entity/**/*.ts'
],
synchronize: true,
logging: false,
}).then(connection => {
console.log('Connected to database!');
}).catch(error => console.log(error));
import { Entity, Column, PrimaryGeneratedColumn } from 'typeorm';
@Entity()
export class User {
@PrimaryGeneratedColumn()
id: number;
@Column()
name: string;
@Column()
email: string;
}
import { Entity, Column, PrimaryGeneratedColumn, ManyToOne, OneToMany } from 'typeorm';
@Entity()
export class Post {
@PrimaryGeneratedColumn()
id: number;
@Column()
title: string;
@ManyToOne(type => User, user => user.posts)
author: User;
}
@Entity()
export class User {
@PrimaryGeneratedColumn()
id: number;
@Column()
name: string;
@Column()
email: string;
@OneToMany(type => Post, post => post.author)
posts: Post[];
}
import { getRepository } from 'typeorm';
import { User } from './entity/User';
const userRepository = getRepository(User);
// 查找所有用户
const users = await userRepository.find();
// 查找特定用户
const user = await userRepository.findOne(1); // 通过 ID 查找
const userByEmail = await userRepository.findOne({ where: { email: 'example@example.com' } }); // 通过条件查找
import { getRepository } from 'typeorm';
import { User } from './entity/User';
const userRepository = getRepository(User);
const users = await userRepository.createQueryBuilder('user')
.where('user.name = :name', { name: 'John Doe' })
.andWhere('user.email LIKE :email', { email: '%example.com' })
.orderBy('user.id', 'DESC')
.skip(10)
.take(10)
.getMany();
import { getManager } from 'typeorm';
await getManager().transaction(async transactionalEntityManager => {
const user = new User();
user.name = 'John Doe';
user.email = 'john.doe@example.com';
await transactionalEntityManager.save(user);
const post = new Post();
post.title = 'First Post';
post.author = user;
await transactionalEntityManager.save(post);
});
import { getManager } from 'typeorm';
try {
await getManager().transaction(async transactionalEntityManager => {
const user = new User();
user.name = 'John Doe';
user.email = 'john.doe@example.com';
await transactionalEntityManager.save(user);
const post = new Post();
post.title = 'First Post';
post.author = user;
await transactionalEntityManager.save(post);
throw new Error('Something went wrong!');
});
} catch (error) {
console.error(error);
}
typeorm migration:create -n CreateUsersTable
import { MigrationInterface, QueryRunner } from 'typeorm';
export class CreateUsersTable1604123456789 implements MigrationInterface {
public async up(queryRunner: QueryRunner): Promise<void> {
await queryRunner.query(
`CREATE TABLE users (
id SERIAL PRIMARY KEY,
name VARCHAR NOT NULL,
email VARCHAR NOT NULL UNIQUE
)`
);
}
public async down(queryRunner: QueryRunner): Promise<void> {
await queryRunner.query(`DROP TABLE users`);
}
}
typeorm migration:run
typeorm migration:revert
通过环境变量来配置数据库连接信息，可以提高代码的可维护性和安全性。
通过定义通用的实体和方法，可以减少重复代码，提高开发效率。
对于涉及多个数据库操作的业务逻辑，使用事务处理可以确保数据的一致性。
通过迁移管理，可以方便地管理数据库结构的变化，确保数据库模式与应用程序保持同步。
开启日志记录可以帮助调试和优化数据库操作。
博客系统通常包含用户、文章和评论等模块。通过 TypeORM，可以方便地管理这些模块的数据关系和操作。
电商系统通常包含商品、订单和用户等模块。通过 TypeORM，可以方便地管理这些模块的数据关系和操作。
随着 TypeScript 和 Node.js 的发展，TypeORM 将继续改进和完善，提供更多强大的功能。
TypeORM 拥有活跃的社区支持，可以及时获得帮助和反馈。
随着技术的成熟和文档的完善，TypeORM 将在更多的项目中得到应用，成为主流的 ORM 解决方案。
TypeORM 是一个功能强大且易用的 ORM 库，适用于 TypeScript 和 JavaScript 的 Node.js 应用程序。通过本文的介绍和实际案例，希望读者能够更好地理解和应用 TypeORM，提升开发效率和代码质量。
- TypeORM. (2021). TypeORM Documentation.
- Roman Kuba. (2018). TypeORM: The Complete Developer's Guide.
- Basarat Ali Syed. (2017). Learning TypeScript.
以下是一个简单的 TypeORM 应用示例，展示了如何定义实体、连接数据库和执行查询。
import { Entity, Column, PrimaryGeneratedColumn } from 'typeorm';
@Entity()
export class User {
@PrimaryGeneratedColumn()
id: number;
@Column()
name: string;
@Column()
email: string;
}
import { createConnection } from 'typeorm';
createConnection({
type: 'mysql',
host: 'localhost',
port: 3306,
username: 'test',
password: 'test',
database: 'test',
entities: [
__dirname + '/entity/**/*.ts'
],
synchronize: true,
logging: false,
}).then(connection => {
console.log('Connected to database!');
}).catch(error => console.log(error));
import { getRepository } from 'typeorm';
import { User } from './entity/User';
const userRepository = getRepository(User);
// 查找所有用户
const users = await userRepository.find();
console.log(users);
// 查找特定用户
const user = await userRepository.findOne(1); // 通过 ID 查找
console.log(user);
const userByEmail = await userRepository.findOne({ where: { email: 'example@example.com' } }); // 通过条件查找
console.log(userByEmail);
这个示例展示了如何使用 TypeORM 定义实体、连接数据库和执行查询。
