Aller au contenu principal
Version: 3.0.0

TypeORM

TypeORM is the most mature object relation mapper (ORM) in the existing community of node.js. This article describes how to use TypeORM in Midway.

astuce

This module is a new version from v3.4.0. The module name has changed and the history is partially compatible. For more information about how to query historical documents, see here.

Related information:

Description
Can be used for standard projects
Can be used for Serverless
Can be used for integration
Contains independent main framework
Contains independent logs

The difference with the old writing

The old module is @midwayjs/orm and the new module is @midwayjs/typeorm. The differences are as follows:

    1. Different package names
    1. Adjust some configurations in src/config.default
    • The key in the 2.1 configuration file is different (orm => typeorm)
    • The 2.2 is modified to the form of a data source to typeorm.dataSource
    • The path to 2.3 an entity model class or an entity model class needs to be declared in the entities field of the data source.
    • 2.4 Subscriber need to be declared in the subscribers field of the data source
  • 3, no longer use the EntityModel decorator, directly use the ability provided by the typeorm

Installation Components

Install typeorm components to provide database ORM capability.

$ npm i @midwayjs/typeorm@3 typeorm --save

Or reinstall the following dependencies in package.json.

{
"dependencies": {
"@midwayjs/typeorm": "^3.0.0",
"typeorm": "~0.3.0 ",
// ...
},
"devDependencies": {
// ...
}
}

Introducing components

Introducing orm components in src/configuration.ts, an example is as follows.

// configuration.ts
import { Configuration } from '@midwayjs/core';
import * as orm from '@midwayjs/typeorm';
import { join } from 'path';

@Configuration({
imports: [
// ...
orm, // enable typeorm component
],
importConfigs: [
join(__dirname, './config')
]
})
export class MainConfiguration {

}

Install database Driver

The commonly used database drivers are as follows. Select the database type to install the corresponding connection:

# for MySQL or MariaDB, you can also use mysql2 instead
npm install mysql --save
npm install mysql2 --save

# for PostgreSQL or CockroachDB
npm install pg --save

# for SQLite
npm install sqlite3 --save

# for Microsoft SQL Server
npm install mssql --save

# for SQL .js
npm install SQL .js --save

# for Oracle
npm install oracledb --save

# for MongoDB(experimental)
npm install mongodb --save
info
  • Oracle driver is special, you need to view the documentation
  • typeorm link mongodb is not recommended, please use mongoose components

Simple directory structure

We take a simple project as an example, please refer to other structures.

MyProject
├── src // TS root directory
│ ├── config
│ │ └── config.default.ts // Application Profile
│ ├── entity // entity (database Model) directory
│ │ └── photo.entity.ts // entity file
│ │ └── photoMetadata.ts
│ ├── configuration.ts // Midway configuration file
│ └── service // Other service directory
├── .gitignore
├── package.json
├── README.md
└── tsconfig.json

Here, our database entities are mainly located in the entity directory (non-mandatory). This is a simple convention.

Getting Started

Next, we will take mysql as an example.

1. Create Model

We associate with the database through the model. The model in the application is the database table. In the TypeORM, the model is bound to the entity. Each Entity file is a Model and an Entity.

In the example, you need an entity. Let's take photo as an example. Create an entity directory and add the entity file photo.entity.ts to the entity directory. A simple entity is as follows.

// entity/photo.entity.ts
export class Photo {
id: number;
name: string;
description: string;
filename: string;
views: number;
isPublished: boolean;
}

Note that each attribute of the entity file here is actually one-to-one corresponding to the database table. Based on the existing database table, we add content up.

2. Define the entity model

Entity is used to define an entity model class.

// entity/photo.entity.ts
import { Entity } from 'typeorm';

@Entity('photo')
export class Photo {
id: number;
name: string;
description: string;
filename: string;
views: number;
isPublished: boolean;
}

If the table name is different from the current entity name, you can specify it in the parameter.

// entity/photo.entity.ts
import { Entity } from 'typeorm';

@Entity('photo_table_name')
export class Photo {
id: number;
name: string;
description: string;
filename: string;
views: number;
isPublished: boolean;
}

These entity columns can also be generated using typeorm_generator tools.

3. Add database columns

The properties are modified by the @Column decorator provided by the typeorm, each corresponding to a column.

// entity/photo.entity.ts
import { Entity, Column } from 'typeorm';

@Entity()
export class Photo {

@Column()
id: number;

@Column()
name: string;

@Column()
description: string;

@Column()
filename: string;

@Column()
views: number;

@Column()
isPublished: boolean;

}

The id, name, description, filename, views, isPublished columns are added to the photo table. The column types in the database are inferred according to the attribute types you use, for example, number will be converted to integers, strings will be converted to varchar, boolean values will be converted to bool, and so on. However, you can use any column type supported by the database by explicitly specifying the column type in the @Column decorator.

We generated a database table with columns, but there is one thing left. Each database table must have a column with a primary key.

Database columns include more column options (ColumnOptions), such as modifying column names, specifying column types, and column lengths. For more options, see the [official documentation](https://github.com/typeorm/typeorm/blob/master/docs/zh_CN/entities.md#%E5%88% 97% E9%80% 89% E9%A1%B9).

4. Create a primary key column

Each entity must have at least one primary key column. To make a column a primary key, you need to use the @PrimaryColumn decorator.

// entity/photo.entity.ts
import { Entity, Column, PrimaryColumn } from 'typeorm';

@Entity()
export class Photo {

@PrimaryColumn()
id: number;

@Column()
name: string;

@Column()
description: string;

@Column()
filename: string;

@Column()
views: number;

@Column()
isPublished: boolean;

}

5. Create an auto-incrementing primary key column

Now, if you want to set the self-increasing id column, you need to change the @PrimaryColumn decorator to the @PrimaryGeneratedColumn decorator:

// entity/photo.entity.ts
import { Entity, Column, PrimaryGeneratedColumn } from 'typeorm';

@Entity()
export class Photo {

@PrimaryGeneratedColumn()
id: number;

@Column()
name: string;

@Column()
description: string;

@Column()
filename: string;

@Column()
views: number;

@Column()
isPublished: boolean;

}

6. Column data type

Next, let's adjust the data type. By default, strings map to types similar to varchar(255) (depending on the database type). Number is mapped to an integer-like type (depending on the database type). However, we do not want all columns to be limited to varchars or integers. Some changes can be made at this time.

// entity/photo.entity.ts
import { Entity, Column, PrimaryGeneratedColumn } from 'typeorm';

@Entity()
export class Photo {

@PrimaryGeneratedColumn()
id: number;

@Column({
length: 100
})
name: string;

@Column('text')
description: string;

@Column()
filename: string;

@Column("double")
views: number;

@Column()
isPublished: boolean;
}

Example, different column names

@Column({
length: 100,
name: 'custom_name'
})
name: string;

Example, different column names

  • @CreateDateColumn is a special column that automatically inserts dates for entities.
  • The @UpdateDateColumn is a special column that automatically updates the entity date each time the entity manager or save of the repository is called.
  • The @VersionColumn is a special column that automatically increases the entity version (increment number) each time the entity manager or save of the repository is called.
  • @DeleteDateColumn is a special column that automatically sets the deletion time of the entity when soft-delete is called.

For example:

  @CreateDateColumn({
type: 'timestamp',
})
createdDate: Date;

The column type is database-specific. You can set any column type supported by the database. For more information about supported column types, see here.

astuce

CreateDateColumn and UpdateDateColumn rely on the insertion date function of creating the default data on the column when the table structure is synchronized for the first time. If the table is created by yourself, you need to add the default data to the column.

7. Configure connection information and entity model

For more information, see Configuration.

Then configure the database connection information in config.default.ts.

// src/config/config.default.ts
import { Photo } from '../entity/photo.entity';

export default {
// ...
typeorm: {
dataSource: {
default: {
/**
* Single database instance
*/
type: 'mysql',
host: '*******',
port: 3306,
username: '*******',
password: '*******',
database: undefined,
synchronize: false, // If it is used for the first time, there is no table, and there is a need for synchronization, you can write true
logging: false,

// Configure the entity model
entities: [Photo],

// or scan format,For compatibility we can match .js and .ts at the same time
entities: [
'entity', // Specific directory
'**/*.entity.{j,t}s', // wildcard path + suffix matching
]
}
}
},
}
astuce
    1. If the database you are using already has the function of table structure synchronization, such as cloud database, it is better not to open it. If it must be used, it is best to use the synchronize configuration only in the development phase or for the first time to avoid consistency problems.
    1. The entities field configuration has been processed by the framework, please do not refer to the original document for this field configuration.

You can use other database types for the type field, including mysql, mariadb, postgres, cockroachdb, sqlite, mssql, oracle, cordova, nativescript, react-native, expo, or mongodb

For example, sqlite requires the following information.

// src/config/config.default.ts
export default {
// ...
typeorm: {
dataSource: {
default: {
type: 'sqlite',
database: path.join(__dirname, '../../test.sqlite')
synchronize: true,
logging: true
// ...
}
}
},
}
info

Note: synchronize fields are used to synchronize table structures. It is not safe to use synchronize: true for production mode synchronization. Please set this field to false after going online.

8. Use Model to insert database data

In common Midway files, use the @InjectEntityModel decorator to inject our configured Model. All we need to do is:

    1. Create entity objects
    1. Execute the save()
import { Provide } from '@midwayjs/core';
import { InjectEntityModel } from '@midwayjs/typeorm';
import { Photo } from '../entity/photo.entity';
import { Repository } from 'typeorm';

@Provide()
export class PhotoService {

@InjectEntityModel(Photo)
photoModel: Repository<Photo>;

// save
async savePhoto() {
// create a entity object
let photo = new Photo();
photo.name = 'Me and Bears';
photo.description = 'I am near polar bears';
photo.filename = 'photo-with-bears.jpg';
photo.views = 1;
photo.isPublished = true;

// save entity
const photoResult = await this.photoModel.save(photo);

// save success
console.log('photo id =', photoResult.id);
}
}

9. Query Data

For more information, see find documentation.

import { Provide } from '@midwayjs/core';
import { InjectEntityModel } from '@midwayjs/typeorm';
import { Photo } from '../entity/photo.entity';
import { Repository } from 'typeorm';

@Provide()
export class PhotoService {

@InjectEntityModel(Photo)
photoModel: Repository<Photo>;

// find
async findPhotos() {

// find All
let allPhotos = await this.photoModel.find({});
console.log("All photos from the db: ", allPhotos);

// find first
let firstPhoto = await this.photoModel.findOne({
where: {
id: 1
}
});
console.log("First photo from the db: ", firstPhoto);

// find one by name
let meAndBearsPhoto = await this.photoModel.findOne({
where: { name: "Me and Bears"}
});
console.log("Me and Bears photo from the db: ", meAndBearsPhoto);

// find by views
let allViewedPhotos = await this.photoModel.find({
where: { views: 1}
});
console.log("All viewed photos: ", allViewedPhotos);

let allPublishedPhotos = await this.photoModel.find({
where: { isPublished: true}
});
console.log("All published photos: ", allPublishedPhotos);

// find and get count
let [allPhotos, photosCount] = await this.photoModel.findAndCount({});
console.log("All photos: ", allPhotos);
console.log("Photos count: ", photosCount);

}
}

10. Update the database

Now, let's load a photo from the database, update it and save it.

import { Provide } from '@midwayjs/core';
import { InjectEntityModel } from '@midwayjs/typeorm';
import { Photo } from '../entity/photo.entity';
import { Repository } from 'typeorm';

@Provide()
export class PhotoService {

@InjectEntityModel(Photo)
photoModel: Repository<Photo>;

async updatePhoto() {

let photoToUpdate = await this.photoModel.findOne({
where: {
id: 1,
},
});
photoToUpdate.name = "Me, my friends and polar bears";

await this.photoModel.save(photoToUpdate);
}
}

11. Delete data

remove is used to remove the given entity or array of entities. delete is used to delete by a given ID or condition.

import { Provide } from '@midwayjs/core';
import { InjectEntityModel } from '@midwayjs/typeorm';
import { Photo } from '../entity/photo.entity';
import { Repository } from 'typeorm';

@Provide()
export class PhotoService {

@InjectEntityModel(Photo)
photoModel: Repository<Photo>;

async updatePhoto() {
/*...*/
const photo = await this.photoModel.findOne({
where: {
id: 1,
},
});

// Remove by entity
await this.photoModel.remove(photo)
// Delete multiple entities
await this.photoModel.remove([photo1, photo2, photo3]);

// Delete by ID
await this.photoModel.delete(1);
await this.photoModel.delete([1, 2, 3]);
await this.photoModel.delete({ name: "Timber" });
}
}

Now, Photo with ID = 1 will be deleted from the database.

There is also a soft deletion method.

await this.photoModel.softDelete(1);
// And You can restore it using restore;
await this.photoModel.restore(1);

12. Create a one-to-one association

Let's create a one-to-one relationship with another class. Let's create a new class in entity/photoMetadata.ts. This class contains additional meta-information for photo.

import { Entity, Column, PrimaryGeneratedColumn, OneToOne, JoinColumn } from 'typeorm';
import { Photo } from './photo';

@Entity()
export class PhotoMetadata {

@PrimaryGeneratedColumn()
id: number;

@Column("int")
height: number;

@Column("int")
width: number;

@Column()
orientation: string;

@Column()
compressed: boolean;

@Column()
comment: string;

@OneToOne(type => Photo)
@JoinColumn()
photo: Photo;

}

Here, we use a new fitting called @OneToOne. It allows us to create a one-to-one relationship between two entities. type => photo is a function that returns the class of the entity with which we want to establish a relationship.

Due to the particularity of the language, we are forced to use a function that returns the class instead of using the class directly. You can also write it as () => Photo, but we use type => Photo as a convention to improve the readability of the code. The type variable itself contains nothing.

We also added an @JoinColumn decorator, which indicates that this side of the relationship will have the relationship. Relationships can be one-way or two-way. The relationship can only be owned by one party. The owner side of the relationship needs to use the @JoinColumn decorator. If you run the application, you will see a newly generated table that will contain a column containing foreign keys for the Photo relationship.

+-------------+--------------+----------------------------+
| photo_metadata |
+-------------+--------------+----------------------------+
| id | int(11) | PRIMARY KEY AUTO_INCREMENT |
| height | int(11) | |
| width | int(11) | |
| comment | varchar(255) | |
| compressed | boolean | |
| orientation | varchar(255) | |
| photoId | int(11) | FOREIGN KEY |
+-------------+--------------+----------------------------+

Next we will associate them in the code.

import { Provide, Inject } from '@midwayjs/core';
import { InjectEntityModel } from '@midwayjs/typeorm';
import { Photo } from './entity/photo.entity';
import { PhotoMetadata } from './entity/photoMetadata.entity';
import { Repository } from 'typeorm';

@Provide()
export class PhotoService {

@InjectEntityModel(Photo)
photoModel: Repository<Photo>;

@InjectEntityModel(PhotoMetadata)
photoMetadataModel: Repository<PhotoMetadata>;

async updatePhoto() {

// create a photo
let photo = new Photo();
photo.name = "Me and Bears";
photo.description = "I am near polar bears";
photo.filename = "photo-with-bears.jpg";
photo.isPublished = true;

// create a photo metadata
let metadata = new PhotoMetadata();
metadata.height = 640;
metadata.width = 480;
metadata.compressed = true;
metadata.comment = "cybershoot";
metadata.orientation = "portrait";
metadata.photo = photo; // this way we connect them


// first we should save a photo
await this.photoModel.save(photo);

// photo is saved. Now we need to save a photo metadata
await this.photoMetadataModel.save(metadata);

// done
console.log("Metadata is saved, and relation between metadata and photo is created in the database too");
}
}

13. Reverse relation mapping

Relational mapping can be one-way or two-way. When the relationship between PhotoMetadata and Photo is one-way. The owner of the relationship is PhotoMetadata, and Photo knows nothing about PhotoMetadata. This complicates accessing PhotoMetadata from the Photo side. To solve this problem, we add a reverse relational mapping to make the PhotoMetadata and Photo a two-way association. Let's modify our entity.

import { Entity } from 'typeorm';
import { Column, PrimaryGeneratedColumn, OneToOne, JoinColumn } from 'typeorm';
import { Photo } from './photo.entity';

@Entity()
export class PhotoMetadata {

/* ... other columns */

@OneToOne(type => Photo, photo => photo.metadata)
@JoinColumn()
photo: Photo;
}
import { Entity } from 'typeorm';
import { Entity, Column, PrimaryGeneratedColumn, OneToOne } from 'typeorm';
import { PhotoMetadata } from './photoMetadata.entity';

@Entity()
export class Photo {

/* ... other columns */

@OneToOne(type => PhotoMetadata, photoMetadata => photoMetadata.photo)
metadata: PhotoMetadata;
}

Photo => photo.metadata is a function that returns a reverse mapping relationship. Here, we explicitly declare that metadata properties of the Photo class are used to associate PhotoMetadata. In addition to passing functions that return photo properties, you can also directly pass strings to @OneToOne decorators, such as "metadata". But we used this function callback method to make our code writing simpler.

Note that the @JoinColumn decorator will only be used on one side of the relationship map. No matter which side of this decorator you place, you are the owner of the relationship. The owner of the relationship contains columns with foreign keys in the database.

14. Load objects and their dependencies

Now, let's try to load Photo and PhotoMetadata together in a single query. There are two ways to do this, using the find * method or using the QueryBuilder function. Let's first use the find * method. The find * method allows you to specify objects using the FindOneOptions/FindManyOptions interface.

import { Provide, Inject } from '@midwayjs/core';
import { InjectEntityModel } from '@midwayjs/typeorm';
import { Photo } from './entity/photo.entity';
import { Repository } from 'typeorm';

@Provide()
export class PhotoService {

@InjectEntityModel(Photo)
photoModel: Repository<Photo>;

// find
async findPhoto() {
/*...*/
let photos = await this.photoModel.find({ relations: [ 'metadata' ] }); // typeorm@0.2.x
}
}

Here, the value of photos is an array that contains the query results of the entire database, and each photo object contains its associated metadata attribute. Learn more about the Find Options in this document.

Find Options is simple, but if you need more complex queries, you should use QueryBuilder instead. QueryBuilder allows more complex queries to be used in an elegant way.

import { Provide, Inject } from '@midwayjs/core';
import { InjectEntityModel } from '@midwayjs/typeorm';
import { Photo } from './entity/photo.entity';
import { Repository } from 'typeorm';

@Provide()
export class PhotoService {

@InjectEntityModel(Photo)
photoModel: Repository<Photo>;

// find
async findPhoto() {
/*...*/
let photos = await this.photoModel
.createQueryBuilder('photo')
.innerJoinAndSelect('photo.metadata', 'metadata')
.getMany();
}
}

QueryBuilder allows the creation and execution of almost any complex SQL query. When using QueryBuilder, think like creating SQL queries. In this example, "photo" and "metadata" are aliases applied to the selected photos. You can use aliases to access the columns and properties of the selected data.

15. Use cascade operations to automatically save associated objects

Cascade can be set in the relationship when we want to automatically save the associated object every time we save another object. Let's slightly change the @OneToOne decorator of the photo.

export class Photo {
/// ... other columns

@OneToOne(type => PhotoMetadata, metadata => metadata.photo, {
cascade: true
})
metadata: PhotoMetadata;
}

Using cascade allows us to no longer save Photo and PhotoMetadata separately now. Due to the cascade option, metadata objects will be saved automatically.

import { Provide, Inject } from '@midwayjs/core';
import { InjectEntityModel } from '@midwayjs/typeorm';
import { Photo } from './entity/photo.entity';
import { PhotoMetadata } from './entity/photoMetadata.entity';
import { Repository } from 'typeorm';

@Provide()
export class PhotoService {

@InjectEntityModel(Photo)
photoModel: Repository<Photo>;

async updatePhoto() {

// create photo object
let photo = new Photo();
photo.name = "Me and Bears";
photo.description = "I am near polar bears";
photo.filename = "photo-with-bears.jpg";
photo.isPublished = true;

// create photo metadata object
let metadata = new PhotoMetadata();
metadata.height = 640;
metadata.width = 480;
metadata.compressed = true;
metadata.comment = "cybershoot";
metadata.orientation = "portrait";

photo.metadata = metadata; // this way we connect them

// save a photo also save the metadata
await this.photoModel.save(photo);

// done
console.log("Photo is saved, photo metadata is saved too");
}
}

Note that we now set the metadata of Photo instead of setting the Photo attribute of metadata as before. This is only valid when you connect Photo to the PhotoMetadata from the Photo side. If set on the PhotoMetadata side, it will not be saved automatically.

16. Create many-to-one/one-to-many associations

Let's create a many-to-one/one-to-many relationship. Suppose a photo has an author, and each author can have many photos. First, let's create an Author class:

import { Entity } from 'typeorm';
import { Column, PrimaryGeneratedColumn, OneToMany, JoinColumn } from 'typeorm';
import { Photo } from './entity/photo.entity';

@Entity()
export class Author {

@PrimaryGeneratedColumn()
id: number;

@Column()
name: string;

@OneToMany(type => Photo, photo => photo.author) // note: we will create author property in the Photo class below
photos: Photo[];
}

Author contains a reverse relationship. OneToMany and ManyToOne need to appear in pairs.

Now, add the owner of the relationship to the Photo entity:

import { Entity } from 'typeorm';
import { Column, PrimaryGeneratedColumn, ManyToOne } from 'typeorm';
import { PhotoMetadata } from './photoMetadata.entity';
import { Author } from './author.entity';

@Entity()
export class Photo {

/* ... other columns */

@ManyToOne(type => Author, author => author.photos)
author: Author;
}

In a many-to-one/one-to-many relationship, the owner is always many-to-one. This means that the class using the @ManyToOne will store the ID of the related object.

After the application is run, ORM creates the author table:

+-------------+--------------+----------------------------+
| author |
+-------------+--------------+----------------------------+
| id | int(11) | PRIMARY KEY AUTO_INCREMENT |
| name | varchar(255) | |
+-------------+--------------+----------------------------+

It also modifies the photo table, adds a new author column, and creates a foreign key for it:

+-------------+--------------+----------------------------+
| photo |
+-------------+--------------+----------------------------+
| id | int(11) | PRIMARY KEY AUTO_INCREMENT |
| name | varchar(255) | |
| description | varchar(255) | |
| filename | varchar(255) | |
| isPublished | boolean | |
| authorId | int(11) | FOREIGN KEY |
+-------------+--------------+----------------------------+

17. Create many-to-many associations

Let's create a many-to-one/many-to-many relationship. Suppose a photo can be in many albums, and each album can contain many photos. Let's create an Album class.

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

@Entity()
export class Album {

@PrimaryGeneratedColumn()
id: number;

@Column()
name: string;

@ManyToMany(type => Photo, photo => photo.albums)
@JoinTable()
photos: Photo[];
}

@JoinTable is used to indicate that this is the owner of the relationship.

Now, add the reverse association to Photo.

export class Photo {
/// ... other columns

@ManyToMany(type => Album, album => album.photos)
albums: Album[];
}

After running the application, ORM will create a album_photos_photo_albums join table:

+-------------+--------------+----------------------------+
| album_photos_photo_albums |
+-------------+--------------+----------------------------+
| album_id | int(11) | PRIMARY KEY FOREIGN KEY |
| photo_id | int(11) | PRIMARY KEY FOREIGN KEY |
+-------------+--------------+----------------------------+

Now, let's insert albums and photos into the database:

import { Provide, Inject } from '@midwayjs/core';
import { InjectEntityModel } from '@midwayjs/typeorm';
import { Photo } from './entity/photo.entity';
import { Album } from './entity/album.entity';
import { Repository } from 'typeorm';

@Provide()
export class PhotoService {

@InjectEntityModel(Photo)
photoModel: Repository<Photo>;

@InjectEntityModel(Album)
albumModel: Repository<Album>

async updatePhoto() {

// create a few albums
let album1 = new Album();
album1.name = "Bears";
await this.albumModel.save(album1);

let album2 = new Album();
album2.name = "Me";
await this.albumModel.save(album2);

// create a few photos
let photo = new Photo();
photo.name = "Me and Bears";
photo.description = "I am near polar bears";
photo.filename = "photo-with-bears.jpg";
photo.albums = [album1, album2];
await this.photoModel.save(photo);


// now our photo is saved and albums are attached to it
// now lets load them:
const loadedPhoto = await this.photoModel.findOne(1, { relations: ["albums"] }); // typeorm@0.2.x
}
}

The loadedPhoto value is:

{
id: 1,
name: "Me and Bears ",
description: "I am near polar bears ",
filename: "photo-with-bears.jpg ",
albums: [{
id: 1,
name: "Bears"
}, {
id: 2,
name: "Me"
}]
}

18. Use QueryBuilder

You can use QueryBuilder to build almost any complex SQL query. For example, you can do this:

let photos = await this.photoModel
.createQueryBuilder("photo") // first argument is an alias. Alias is what you are selecting - photos. You must specify it.
.innerJoinAndSelect("photo.metadata", "metadata")
.leftJoinAndSelect("photo.albums", "album")
.where("photo.isPublished = true")
.andWhere("(photo.name = :photoName OR photo.name = :bearName)")
.orderBy("photo.id", "DESC")
.skip(5)
.take(10)
.setParameters({ photoName: "My", bearName: "Mishka" })
.getMany();

The query selects all published photos with "My" or "Mishka" names. It will return results (paging offset) from position 5, and only 10 results (paging limit) will be selected. The selection results will be sorted in descending order of ID. The photo album will be left-Joined and metadata will be automatically associated.

You will use query generators extensively in your application. Learn more about QueryBuilder here.

19. Event Subscriber

typeorm provides an event subscription mechanism to facilitate log output when doing some database operations. For this reason, midway provides a EventSubscriberModel decorator to label event subscription classes with the following code.

import { EventSubscriberModel } from '@midwayjs/typeorm';
import { EntitySubscriberInterface, InsertEvent, UpdateEvent, RemoveEvent } from 'typeorm';

@EventSubscriberModel()
export class EverythingSubscriber implements EntitySubscriberInterface {

/**
* Called before entity insertion.
*/
beforeInsert(event: InsertEvent<any>) {
console.log('BEFORE ENTITY INSERTED:', event.entity);
}

/**
* Called before entity insertion.
*/
beforeUpdate(event: UpdateEvent<any>) {
console.log('BEFORE ENTITY UPDATED:', event.entity);
}

/**
* Called before entity insertion.
*/
beforeRemove(event: RemoveEvent<any>) {
console.log('BEFORE ENTITY WITH ID ${event.entityId} REMOVED:', event.entity);
}

/**
* Called after entity insertion.
*/
afterInsert(event: InsertEvent<any>) {
console.log('AFTER ENTITY INSERTED:', event.entity);
}

/**
* Called after entity insertion.
*/
afterUpdate(event: UpdateEvent<any>) {
console.log('AFTER ENTITY UPDATED:', event.entity);
}

/**
* Called after entity insertion.
*/
afterRemove(event: RemoveEvent<any>) {
console.log('AFTER ENTITY WITH ID ${event.entityId} REMOVED:', event.entity);
}

/**
* Called after entity is loaded.
*/
afterLoad(entity: any) {
console.log('AFTER ENTITY LOADED:', entity);
}

}

This subscription class provides some common interfaces to perform some things during database operations.

At the same time, we need to add subscription classes to the configuration.

// src/config/config.default.ts
import { EverythingSubscriber } from '../event/subscriber';

export default {
// ...
typeorm: {
dataSource: {
default: {
// ...
entities: [Photo],
// Incoming subscription class
subscribers: [EverythingSubscriber]
}
}
},
}

Repository API

For more APIs, please check official website documentation.

Advanced features

Multi-dataSource support

Sometimes, we have multiple database connections (Connection) in an application, and there will be multiple configurations at this time. We use the DataSource standard form of object to define the configuration.

For example, the following defines two database connections (Connection), default and test.

import { join } from 'path';

export default {
typeorm: {
dataSource: {
default: {
type: 'sqlite',
database: join(__dirname, '../../default.sqlite')
// ...
},
test: {
type: 'mysql',
host: '127.0.0.1',
port: 3306
// ...
}
}
}
}

In use, you need to specify which connection (Connection) the model belongs.

import { InjectEntityModel } from '@midwayjs/typeorm';
import { User } from './entity/user.entity';

export class XXX {

@InjectEntityModel(User, 'test')
testUserModel: Repository<User>;

//...
}

Column value conversion

We can handle column value conversions in the entity definition.

The transformer parameters of the column decorator can be used to process entry and exit parameters, such as formatting time.

import { Entity, Column, CreateDateColumn, PrimaryGeneratedColumn, UpdateDateColumn } from 'typeorm';
import * as dayjs from 'dayjs';

const dateTransformer = {
from: (value: Date | number) => {
return dayjs(typeof value === 'number '? value: value.getTime()).format('YYYY-MM-DD HH:mm:ss');
},
to: () => new Date()
};

@Entity()
export class Photo {
// ...

@CreateDateColumn({
type: 'timestamp',
transformer: dateTransformer
})
createdAt: Date;
}

Specify the default data source

When including multiple data sources, you can specify a default data source.

export default {
// ...
typeorm: {
dataSource: {
default1: {
// ...
},
default2: {
// ...
},
},
// 多个数据源时可以用这个指定默认的数据源
defaultDataSourceName: 'default1',
},
};

Get data source

The data source is the DataSource object of TypeORM created, which we can obtain by injecting the built-in data source manager.

import { Configuration } from '@midwayjs/core';
import { TypeORMDataSourceManager } from '@midwayjs/typeorm';

@Configuration({
// ...
})
export class MainConfiguration {

async onReady(container: IMidwayContainer) {
const dataSourceManager = await container.getAsync(TypeORMDataSourceManager);
const conn = dataSourceManager.getDataSource('default');
console.log(dataSourceManager.isConnected(conn));
}
}

Starting with v3.8.0, it is also possible to inject via a decorator.

import { Configuration } from '@midwayjs/core';
import { InjectDataSource } from '@midwayjs/typeorm';
import { DataSource } from 'typeorm';

@Configuration({
//...
})
export class MainConfiguration {

// Inject the default data source
@InjectDataSource()
defaultDataSource: DataSource;

// inject custom data source
@InjectDataSource('default1')
customDataSource: DataSource;

async onReady(container: IMidwayContainer) {
//...
}
}

Logging

When the data source does not configure a log object, the component will automatically create a typeormLogger to save the executed SQL information, which is convenient for troubleshooting and SQL audit.

The default configuration is:

export default {
midwayLogger: {
clients: {
typeormLogger: {
fileLogName: 'midway-typeorm.log',
enableError: false,
level: 'info',
},
},
}
}

We can use the normal log configuration method to make adjustments. If you do not want to generate logs, you can configure them to close.

export default {
// ...
typeorm: {
default: {
// All data sources closed
logging: false,
},
dataSource: {
default: {
// Single data source closed
logging: false,
},
},
},
};

Transaction

The typeorm transaction needs to get the data source first and then open the transaction.

import { Provide, Inject } from '@midwayjs/core';
import { TypeORMDataSourceManager } from '@midwayjs/typeorm';
import { UserDTO } from '../entity/user';

@Provide()
export class UserService {

@Inject()
dataSourceManager: TypeORMDataSourceManager;

async updateUser(user: UserDTO) {

// get dataSource
const dataSource = this.dataSourceManager.getDataSource('default');

// start transaction
await dataSource.transaction(async (transactionalEntityManager) => {
// run code
await transactionalEntityManager.save(UserDTO, user);
});
}

}

For more information, see Documentation.

CLI

TypeORM provides a CLI by default to create entity, migration, etc. For more documents, please see here .

Since the default configuration of TypeORM is different from Midway, we provide a simple modified version to adapt to Midway's data source configuration.

Check the installation:

$ npx mwtypeorm -h

Commonly used commands are

Create Empty Entity

A src/entity/User.ts file will be created.

$ npx mwtypeorm entity:create src/entity/User

Create Migration

A src/migration/******-photo.entity.ts file will be generated based on the existing data source.

For example, the configuration is as follows:

export default {
typeorm: {
dataSource: {
'default': {
//...
entities: [
'**/entity/*.entity{.ts,.js}'
],
migrations: [
'**/migration/*.ts'
],
},
},
}

You can execute the following command to generate a migration file for the modified Entity.

$ npx mwtypeorm migration:generate -d ./src/config/config.default.ts src/migration/photo
attention

Note: Since the above entities configuration needs to be reused between CLI and Midway, the scanning method supported by both is adopted.

About Table Structure Synchronization

  • If you already have a table structure, you want to automatically create an Entity and use the Generator
  • If you already have Entity code, if you want to create a table structure, please use synchronize: true in the configuration, be aware that data may be lost
  • If it is already online, but the table structure has been modified, you can use migration:generate in the CLI

Frequently Asked Questions

Handshake inactivity timeout

Generally, it is due to network reasons. If it appears locally, you can ping but telnet is not available. You can try to execute the following command:

$sudo sysctl -w net.inet.tcp.sack=0

Time Zone Display of mysql Time Column

In general, UTC time is stored in the database. If you want to return the time in the current time zone, you can use the following method

1. Check the environment where the mysql database is located.

For example, the default time zone is the system UTC time, which can be adjusted to +08:00.

mysql> show global variables like '%time_zone%';
+------------------+--------+
| Variable_name | Value |
+------------------+--------+
| system_time_zone | UTC |
| time_zone | SYSTEM |
+------------------+--------+
2 rows in set (0.05 sec)

2. Check the environment where the service code is deployed.

Try to be consistent with the environment where the database is located. If not, set the timezone in the configuration (set to be consistent with mysql).

export default {
typeorm: {
dataSource: {
default: {
type: 'mysql',
// ...
timezone: '+08:00',
},
},
},
}

Time column returns string

Configuring dateStrings can make mysql return time in DATETIME format, which is only valid for mysql.

// src/config/config.default.ts
export default {
// ...
typeorm: {
dataSource: {
default: {
//...
dateStrings: true
}
}
},
}

Entity return types can be adjusted if @CreateDateColumn and @UpdateDateColumn are used.

@UpdateDateColumn({
name: "gmt_modified",
type: 'timestamp'
})
gmtModified: string;

@CreateDateColumn({
name: "gmt_create",
type: 'timestamp',
})
gmtCreate: string;

The effect is as follows:

Before configuration:

gmtModified: 2021-12-13T03:49:43.000Z
gmtCreate: 2021-12-13T03:49:43.000Z

After configuration:

gmtModified: '2021-12-13 11:49:43',
gmtCreate: '2021-12-13 11:49:43'

Install mysql and mysql2 at the same time

When you have both mysql and mysql2 in node_modules, typeorm will automatically load mysql instead of mysql2.

If you need to use mysql2 at this time, please specify the driver.

// src/config/config.default.ts
export default {
// ...
typeorm: {
dataSource: {
default: {
//...
type: 'mysql',
driver: require('mysql2')
}
}
},
}

Cannot read properties of undefined (reading 'getRepository')

Generally, the configuration is incorrect, and two configurations can be considered.

    1. Check whether the entities configuration in config.default.ts is correct
    1. Check the configuration.ts file to confirm whether orm is imported