使用多个连接
使用多个数据库的最简单方法是创建不同的连接：
import {createConnections} from "typeorm";
const connections = await createConnections([{
name: "db1Connection",
type: "mysql",
host: "localhost",
port: 3306,
username: "root",
password: "admin",
database: "db1",
entities: [__dirname + "/entity/*{.js,.ts}"],
synchronize: true
}, {
name: "db2Connection",
type: "mysql",
host: "localhost",
port: 3306,
username: "root",
password: "admin",
database: "db2",
entities: [__dirname + "/entity/*{.js,.ts}"],
synchronize: true
}]);
此方法允许你连接到已拥有的任意数量的数据库，每个数据库都有自己的配置，自己的实体和整体ORM范围和设置。
对于每个连接，将创建一个新的Connection实例。 你必须为创建的每个连接指定唯一的名称。
也可以从ormconfig文件加载所有连接选项：
import {createConnections} from "typeorm";
const connections = await createConnections();
指定要按名称创建的连接：
import {createConnection} from "typeorm";
const connection = await createConnection("db2Connection");
使用连接时，必须指定连接名称以获取特定连接：
import {getConnection} from "typeorm";
const db1Connection = getConnection("db1Connection");
// 现在可以使用"db1"数据库...
const db2Connection = getConnection("db2Connection");
// 现在可以使用"db2"数据库...
使用此方法的好处是你可以使用不同的登录凭据，主机，端口甚至数据库类型来配置多个连接。
但是缺点可能是需要管理和使用多个连接实例。
在单个连接中使用多个数据库
如果你不想创建多个连接，但是想在一个连接中使用多个数据库，则可以指定使用的每个实体的数据库名称：
import {Entity, PrimaryGeneratedColumn, Column} from "typeorm";
@Entity({ database: "secondDB" })
export class User {
@PrimaryGeneratedColumn()
id: number;
@Column()
firstName: string;
@Column()
lastName: string;
}
import {Entity, PrimaryGeneratedColumn, Column} from "typeorm";
@Entity({ database: "thirdDB" })
export class Photo {
@PrimaryGeneratedColumn()
id: number;
@Column()
url: string;
}
user实体将在secondDB数据库内创建，Photo实体则在thirdDB数据库内。
如果要从其他数据库中选择数据，则只需提供一个实体：
const users = await connection
.createQueryBuilder()
.select()
.from(User, "user")
.addFrom(Photo, "photo")
.andWhere("photo.userId = user.id")
.getMany(); // userId因其跨数据库请求而不是外键
此代码将生成以下sql查询（取决于数据库类型）：
SELECT * FROM "secondDB"."question" "question", "thirdDB"."photo" "photo"
WHERE "photo"."userId" = "user"."id"
还可以指定表而不是实体：
const users = await connection
.createQueryBuilder()
.select()
.from("secondDB.user", "user")
.addFrom("thirdDB.photo", "photo")
.andWhere("photo.userId = user.id")
.getMany(); // userId因其跨数据库请求而不是外键
仅在mysql和mssql数据库中支持此功能。
在单个连接中使用多个模式
你可以在应用程序中使用多个模式，只需在每个实体上设置schema：
import {Entity, PrimaryGeneratedColumn, Column} from "typeorm";
@Entity({ schema: "secondSchema" })
export class User {
@PrimaryGeneratedColumn()
id: number;
@Column()
firstName: string;
@Column()
lastName: string;
}
import {Entity, PrimaryGeneratedColumn, Column} from "typeorm";
@Entity({ schema: "thirdSchema" })
export class Photo {
@PrimaryGeneratedColumn()
id: number;
@Column()
url: string;
}
user实体将在secondSchema schema中创建，photo实体将在thirdSchema schema中创建。
其他实体将在默认连接架构中创建。
如果要从其他模式中选择数据，则只需提供一个实体：
const users = await connection
.createQueryBuilder()
.select()
.from(User, "user")
.addFrom(Photo, "photo")
.andWhere("photo.userId = user.id")
.getMany(); // userId因其跨数据库请求而不是外键
此代码将生成以下sql查询（取决于数据库类型）：
SELECT * FROM "secondSchema"."question" "question", "thirdSchema"."photo" "photo"
WHERE "photo"."userId" = "user"."id"
你还可以指定表而不是实体：
const users = await connection
.createQueryBuilder()
.select()
.from("secondSchema.user", "user") // 在mssql中，指定数据库：secondDB.secondSchema.user
.addFrom("thirdSchema.photo", "photo") // 在mssql中，指定数据库：thirdDB.thirdSchema.photo
.andWhere("photo.userId = user.id")
.getMany();
仅在postgres和mssql数据库中支持此功能。
在mssql中，你还可以组合模式和数据库，例如：
import {Entity, PrimaryGeneratedColumn, Column} from "typeorm";
@Entity({ database: "secondDB", schema: "public" })
export class User {
@PrimaryGeneratedColumn()
id: number;
@Column()
firstName: string;
@Column()
lastName: string;
}
主从复制
你可以使用TypeORM设置读/写复制。
复制连接设置示例：
{
type: "mysql",
logging: true,
replication: {
master: {
host: "server1",
port: 3306,
username: "test",
password: "test",
database: "test"
},
slaves: [{
host: "server2",
port: 3306,
username: "test",
password: "test",
database: "test"
}, {
host: "server3",
port: 3306,
username: "test",
password: "test",
database: "test"
}]
}
}
所有模式更新和写入操作都使用master服务器执行。 find方法或select query builder执行的所有简单查询都使用随机的slave实例。
如果要在查询构建器创建的SELECT中显式使用master，可以使用以下代码：
const masterQueryRunner = connection.createQueryRunner("master");
try {
const postsFromMaster = await connection.createQueryBuilder(Post, "post")
.setQueryRunner(masterQueryRunner)
.getMany();
} finally {
await masterQueryRunner.release();
}
请注意，需要显式释放由QueryRunner创建的连接。
mysql，postgres和sql server数据库都支持复制。
Mysql支持深度配置：
{
replication: {
master: {
host: "server1",
port: 3306,
username: "test",
password: "test",
database: "test"
},
slaves: [{
host: "server2",
port: 3306,
username: "test",
password: "test",
database: "test"
}, {
host: "server3",
port: 3306,
username: "test",
password: "test",
database: "test"
}],
/**
* 如果为true，则PoolCluster将在连接失败时尝试重新连接。 （默认值：true）
*/
canRetry: true,
/**
* 如果连接失败，则节点的errorCount会增加。
* 当errorCount大于removeNodeErrorCount时，删除PoolCluster中的节点。 （默认值：5）
*/
removeNodeErrorCount: 5,
/**
* 如果连接失败，则指定在进行另一次连接尝试之前的毫秒数。
* 如果设置为0，则将删除节点，并且永远不会重复使用。 （默认值：0）
*/
restoreNodeTimeout: 0,
/**
* 确定如何选择从库：
* RR：交替选择一个（Round-Robin）。
* RANDOM: 通过随机函数选择节点。
* ORDER: 无条件选择第一个
*/
selector: "RR"
}
}