数据库连接

什么是Connection

只有在建立连接后才能与数据库进行交互。 TypeORM 的Connection不会像看起来那样设置单个数据库连接，而是设置连接池。 如果你对数据库连接感兴趣，请参阅QueryRunner文档。 QueryRunner的每个实例都是一个独立的数据库连接。一旦调用Connection的connect方法，就建立连接池设置。 如果使用createConnection函数设置连接，则会自动调用connect方法。调用close时会断开连接（关闭池中的所有连接）。 通常情况下，你只能在应用程序启动时创建一次连接，并在完全使用数据库后关闭它。实际上，如果要为站点构建后端，并且后端服务器始终保持运行,则不需要关闭连接。

创建新的连接

有多种方法可以创建连接。但是最简单和最常用的方法是使用createConnection和createConnections函数。

createConnection 创建单个连接：

  1. import { createConnection, Connection } from "typeorm";
  3. const connection = await createConnection({
  4.   type: "mysql",
  5.   host: "localhost",
  6.   port: 3306,
  7.   username: "test",
  8.   password: "test",
  9.   database: "test"
  10. });

只使用url和type也可以进行连接。

  1. createConnection({
  2.   type: "postgres",
  3.   url: "postgres://test:test@localhost/test"
  4. });

createConnections 创建多个连接:

  1. import { createConnections, Connection } from "typeorm";
  3. const connections = await createConnections([
  4.   {
  5.     name: "default",
  6.     type: "mysql",
  7.     host: "localhost",
  8.     port: 3306,
  9.     username: "test",
  10.     password: "test",
  11.     database: "test"
  12.   },
  13.   {
  14.     name: "test2-connection",
  15.     type: "mysql",
  16.     host: "localhost",
  17.     port: 3306,
  18.     username: "test",
  19.     password: "test",
  20.     database: "test2"
  21.   }
  22. ]);

这两种方式都根据你传递的连接选项创建Connection，并调用connect方法。另外你也可以在项目的根目录中创建一个ormconfig.json文件，createConnection和createConnections将自动从此文件中读取连接选项。项目的根目录与node_modules目录的级别相同。

  1. import { createConnection, createConnections, Connection } from "typeorm";
  3. // createConnection将从ormconfig.json / ormconfig.js / ormconfig.yml / ormconfig.env / ormconfig.xml 文件或特殊环境变量中加载连接选项
  4. const connection: Connection = await createConnection();
  6. // 你可以指定要创建的连接的名称
  7. // （如果省略名称，则将创建没有指定名称的连接）
  8. const secondConnection: Connection = await createConnection("test2-connection");
  10. // 如果调用createConnections而不是createConnection
  11. // 它将初始化并返回ormconfig文件中定义的所有连接
  12. const connections: Connection[] = await createConnections();

不同的连接必须具有不同的名称默。认情况下，如果未指定连接名称，则为default。 通常在你使用多个数据库或多个连接配置时才会使用多连接。

创建连接后，你可以使用getConnection函数从应用程序中的任何位置使用它：

  1. import { getConnection } from "typeorm";
  3. // 可以在调用createConnection后使用并解析
  4. const connection = getConnection();
  6. // 如果你有多个连接，则可以按名称获取连接
  7. const secondConnection = getConnection("test2-connection");

应避免额外创建 classes/services 来存储和管理连接。此功能已嵌入到 TypeORM 中 - 无需过度工程并创建无用的抽象。

使用ConnectionManager

你可以使用ConnectionManager类创建连接。例如：

  1. import { getConnectionManager, ConnectionManager, Connection } from "typeorm";
  3. const connectionManager = getConnectionManager();
  4. const connection = connectionManager.create({
  5.   type: "mysql",
  6.   host: "localhost",
  7.   port: 3306,
  8.   username: "test",
  9.   password: "test",
  10.   database: "test"
  11. });
  12. await connection.connect(); // 执行连接

这不是常规创建连接的方法，但它可能对某些用户有用。例如，想要创建连接并存储其实例,同时控制何时建立实际”connection”。你还可以创建和维护自己的ConnectionManager：

  1. import { getConnectionManager, ConnectionManager, Connection } from "typeorm";
  3. const connectionManager = new ConnectionManager();
  4. const connection = connectionManager.create({
  5.   type: "mysql",
  6.   host: "localhost",
  7.   port: 3306,
  8.   username: "test",
  9.   password: "test",
  10.   database: "test"
  11. });
  12. await connection.connect(); // 执行连接

但请注意，使用该方式，你将无法再使用getConnection() - 你需要存储连接管理器实例，并使用connectionManager.get来获取所需的连接。

通常情况下为避免应用程序中出现不必要的复杂情况，应尽量少使用此方法，除非你确实认为需要时才使用ConnectionManager。

使用连接

设置连接后，可以使用getConnection函数在应用程序的任何位置使用它：

  1. import { getConnection } from "typeorm";
  2. import { User } from "../entity/User";
  4. export class UserController {
  5.   @Get("/users")
  6.   getAll() {
  7.     return getConnection().manager.find(User);
  8.   }
  9. }

你也可以使用ConnectionManager＃get来获取连接，但在大多数情况下使用getConnection()就足够了。

使用 Connection，你可以对实体执行数据库操作，尤其是使用连接的EntityManager和Repository。 有关它们的更多信息，请参阅Entity Manager 和 Repository 文档。

但一般来说，你不要太多使用Connection。大多数情况下，你只需创建连接并使用getRepository()和getManager()来访问连接的管理器和存储库，而无需直接使用连接对象：

  1. import { getManager, getRepository } from "typeorm";
  2. import { User } from "../entity/User";
  4. export class UserController {
  5.   @Get("/users")
  6.   getAll() {
  7.     return getManager().find(User);
  8.   }
  10.   @Get("/users/:id")
  11.   getAll(@Param("id") userId: number) {
  12.     return getRepository(User).findOne(userId);
  13.   }
  14. }