TypeORM (@ipare/typeorm)

添加 @ipare/typeorm 插件以使用流行 ORM 工具 TypeORMopen in new window

@ipare/typeorm 的功能基于 TypeORMopen in new window,使用 @ipare/typeorm 可以简化数据库的操作

安装

npm install @ipare/typeorm

快速开始

startup.ts

import '@ipare/typeorm';

// 此示例使用 sqlite,需要在项目中先安装 sqlite 驱动: npm install sqlite3
startup.useTypeorm({
  type: 'sqlite',
  database: './test.db'
})

src/entities 定义实体模型

import { Entity, PrimaryGeneratedColumn, Column } from "typeorm"

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

    @Column()
    firstName: string

    @Column()
    lastName: string

    @Column()
    age: number
}

在中间件或服务通过依赖注入获取数据库连接实例 TypeormInject

import { Middleware } from '@ipare/core';
import { TypeormConnection, TypeormInject } from "@ipare/typeorm";

class TestMiddleware extends Middleware {
  @TypeormInject()
  private readonly dataSource!: TypeormConnection;

  async invoke(): Promise<void> {
    const userRepository = this.dataSource.getRepository(User);

    const user = new User();
    user.firstName = "Timber";
    user.lastName = "Saw";
    user.age = 25;
    await userRepository.save(user);

    const allUsers = await userRepository.find();
    const firstUser = await userRepository.findOneBy({
      id: 1,
    }); // find by id
    const timber = await userRepository.findOneBy({
      firstName: "Timber",
      lastName: "Saw",
    }); // find by firstName and lastName

    await userRepository.remove(timber);

    this.ok({
      firstUser,
      allUsers,
    });
  }
}

多数据库连接

@ipare/typeorm 支持多数据库连接,只需调用多次 useTypeorm ,并传参 identity 用于区分

import '@ipare/typeorm';

startup
  .useTypeorm({
    identity: "db1",
    type: 'sqlite',
    database: './test.db',
    // ...
  })
  .useTypeorm({
    identity: "db2",
    type: 'mysql',
    host: '127.0.0.1',
    // ...
  })

在中间件或服务中,给装饰器 @TypeormInject() 传参以区分连接

import { Middleware } from '@ipare/core';
import { TypeormConnection, TypeormInject } from "@ipare/typeorm";

class TestMiddleware extends Middleware {
  @TypeormInject("db1")
  private readonly dataSource1!: TypeormConnection;
  @TypeormInject("db2")
  private readonly dataSource2!: TypeormConnection;

  async invoke(): Promise<void> {
    const userRepository1 = this.dataSource1.getRepository(User);
    const userRepository2 = this.dataSource2.getRepository(User);
    await this.next();
  }
}

注意

只有在 useTypeorm 之后的中间件,才能获取到数据库连接实例

获取实例

你可以通过依赖注入的方式获取实例,也可以用 ctx.getTypeorm 获取实例

依赖注入

@TypeormInject 装饰属性或构造函数参数,通过 @ipare/inject 依赖注入创建实例

import { Middleware } from "@ipare/core";
import { TypeormConnection, TypeormInject } from "@ipare/typeorm";

@Inject
class TestMiddleware extends Middleware {
  constructor(
    @TypeormInject private readonly connection: TypeormConnection,
    @TypeormInject("id2") private readonly connection2: TypeormConnection
  ) {}

  @TypeormInject("id1")
  private readonly connection1!: TypeormConnection;

  async invoke(): Promise<void> {
    await this.next();
  }
}

ctx.getTypeorm

使用 ctx.getTypeorm 的方式更灵活,但代码易读性不如使用依赖注入

import "@ipare/typeorm";

startup.use(async (ctx, next) => {
  const connection1 = await ctx.getTypeorm("id1");
  const connection2 = await ctx.getTypeorm("id2");
  const connection = await ctx.getTypeorm();
});

生命周期与作用域

作用域

通过 startup.useTypeorm 函数传参 injectType 以修改该实例作用域

参考 https://ipare.org/usage/inject.html#作用域open in new window

import '@ipare/typeorm';

startup
  .useTypeorm({
    type: 'sqlite',
    database: './test.db',
    injectType: InjectType.Singleton
  })

生命周期

数据库连接实例通过依赖注入 @ipare/inject 创建,因此其生命周期符合 @ipare/inject 规则

参考 http://ipare.org/usage/inject.html#生命周期open in new window

销毁的行为是在 startup.useInject 中间件的返回管道中触发,伪代码逻辑如

await initInject(); // 初始化依赖注入
await initializeTypeorm(); // 初始化 Typeorm
await next(); // 执行下个中间件
await dispose(); // 销毁

数据库驱动

参考 https://github.com/typeorm/typeormopen in new window

@ipare/typeorm 没有内置数据库驱动

因此需要配合安装数据库驱动,以支持对应数据库

  • MySQL 或 MariaDB
npm install mysql --save

npm install mysql2 --save
  • PostgreSQL 或 CockroachDB
npm install pg --save
  • SQLite
npm install sqlite3 --save
  • Microsoft SQL Server
npm install mssql --save
  • sql.js
npm install sql.js --save
  • Oracle
npm install oracledb --save

To make the Oracle driver work, you need to follow the installation instructions from their site.

  • SAP Hana
npm install @sap/hana-client
npm install hdb-pool

SAP Hana support made possible by the sponsorship of Neptune Software.

  • Google Cloud Spanner
npm install @google-cloud/spanner --save

数据库实体模型

项目中应该包含 src/entities 目录,默认 src/entities 目录中的数据库实体模型会被自动加载

ipare-project
│── src
│   │── startup.ts
│   │── index.ts
│   └── entities
│       └── user.entity.ts
│       └── todo.entity.ts
│── package.json
└── tsconfig.json

你也可以指定实体模型为其他

startup.useTypeorm({
  entities: [UserEntity, TodoEntity]
})

startup.useTypeorm({
  entities: ['entities/**/*.ts']
})

注意

默认会将 src 目录下的 .ts 文件编译到 dist 目录,因此配置路径时要使用 entities 而不是 src/entities

具体根据不同项目决定路径