PostgreSQL：使用 TypeORM 进行跨模式连接

在本文中，我们将介绍如何使用 PostgreSQL 数据库和 TypeORM 进行跨模式连接。PostgreSQL 是一个功能强大的关系型数据库系统，而 TypeORM 是一个支持多种数据库的 ORM（对象关系映射）工具。

阅读更多：PostgreSQL 教程

背景

在数据库设计中，有时候需要将数据分散在不同的模式中。模式是 PostgreSQL 中用来组织数据库对象的一种方式，类似于其他数据库系统中的“数据库”概念。跨模式连接是指从一个模式中的表中检索数据，并与另一个模式中的表进行关联或聚合查询。

我们假设有两个模式：模式A和模式B，每个模式中都有各自的表。我们将使用 TypeORM 来连接这两个模式，并进行一些查询操作。

步骤

在开始之前，确保你已经正确地设置了 PostgreSQL 数据库，并已经安装了 TypeORM。接下来，我们将按照以下步骤进行设置和演示。

步骤1：创建模式和表

首先，我们需要在 PostgreSQL 中创建模式A和模式B，并在每个模式中创建一些表。可以使用 pgAdmin、psql 或任何其他 PostgreSQL 客户端工具来执行以下 SQL 命令：

-- 创建模式A和模式B
CREATE SCHEMA schema_a;
CREATE SCHEMA schema_b;

-- 在模式A中创建表
CREATE TABLE schema_a.table_a (
    id SERIAL PRIMARY KEY,
    name VARCHAR(100) NOT NULL
);

-- 在模式B中创建表
CREATE TABLE schema_b.table_b (
    id SERIAL PRIMARY KEY,
    value INTEGER NOT NULL,
    table_a_id INTEGER REFERENCES schema_a.table_a (id)
);

步骤2：设置 TypeORM

在你的项目中，首先需要安装 TypeORM 的依赖包。可以使用 npm 或 yarn 执行以下命令：

npm install typeorm --save

接下来，在项目的根目录中创建一个 ormconfig.js 文件，并配置数据库连接：

module.exports = {
   "type": "postgres",
   "host": "localhost",
   "port": 5432,
   "username": "your-username",
   "password": "your-password",
   "database": "your-database",
   "synchronize": true,
   "logging": false,
   "entities": [
      "src/entity/**/*.ts"
   ],
   "migrations": [
      "src/migration/**/*.ts"
   ],
   "subscribers": [
      "src/subscriber/**/*.ts"
   ],
   "cli": {
      "entitiesDir": "src/entity",
      "migrationsDir": "src/migration",
      "subscribersDir": "src/subscriber"
   }
}

注意替换 username、password 和 database 字段的值为你的数据库凭据和名称。

步骤3：创建实体类

在 src/entity 目录中，分别创建以下两个实体类：TableA 和 TableB。分别对应模式A中的 table_a 表和模式B中的 table_b 表。

// src/entity/TableA.ts
import { Entity, PrimaryGeneratedColumn, Column } from "typeorm";

@Entity({ schema: "schema_a", name: "table_a" })
export class TableA {

    @PrimaryGeneratedColumn()
    id: number;

    @Column()
    name: string;

}

// src/entity/TableB.ts
import { Entity, PrimaryGeneratedColumn, Column, ManyToOne, JoinColumn } from "typeorm";
import { TableA } from "./TableA";

@Entity({ schema: "schema_b", name: "table_b" })
export class TableB {

    @PrimaryGeneratedColumn()
    id: number;

    @Column()
    value: number;

    @ManyToOne(() => TableA)
    @JoinColumn({ name: "table_a_id" })
    tableA: TableA;

}

步骤4：进行跨模式连接

现在，我们可以在代码中使用 TypeORM 进行跨模式连接了。假设我们要查询模式B中所有表的值，并与模式A中的表进行关联。以下是一个简单的示例：

import { createConnection, getConnection } from "typeorm";
import { TableA } from "./entity/TableA";
import { TableB } from "./entity/TableB";

createConnection().then(async (connection) => {
    const tableBRepository = connection.getRepository(TableB);
    const tableBs = await tableBRepository.createQueryBuilder("table_b")
        .leftJoinAndSelect("table_b.tableA", "table_a")
        .getMany();

    tableBs.forEach((tableB) => {
        console.log(`TableB ID:  ${tableB.id}, Value:$ {tableB.value}`);
        console.log(`Associated TableA Name: ${tableB.tableA.name}`);
    });

    await getConnection().close();
});

上述代码通过 leftJoinAndSelect 方法在查询中添加了一个左外连接，并使用 table_a 别名引用了模式A中的表。通过这样的查询，我们可以在结果集中获得模式B表及其关联的模式A表的值。