数据查询
数据查询
要从数据库中获取单个结果,例如通过 id 或 name 获取用户,必须使用getOne
:
const timber = await getRepository(User)
.createQueryBuilder("user")
.where("user.id = :id OR user.name = :name", { id: 1, name: "Timber" })
.getOne();
要从数据库中获取多个结果,例如,要从数据库中获取所有用户,请使用getMany
:
const users = await getRepository(User)
.createQueryBuilder("user")
.getMany();
使用查询构建器查询可以获得两种类型的结果:entities或raw results大多数情况下,你只需要从数据库中选择真实实体,例如 users 为此,你可以使用getOne
和getMany
但有时你需要选择一些特定的数据,比方说所有sum of all user photos此数据不是实体,它称为原始数据要获取原始数据,请使用getRawOne
和getRawMany
例如:
const { sum } = await getRepository(User)
.createQueryBuilder("user")
.select("SUM(user.photosCount)", "sum")
.where("user.id = :id", { id: 1 })
.getRawOne();
const photosSums = await getRepository(User)
.createQueryBuilder("user")
.select("user.id")
.addSelect("SUM(user.photosCount)", "sum")
.where("user.id = :id", { id: 1 })
.getRawMany();
// 结果会像这样: [{ id: 1, sum: 25 }, { id: 2, sum: 13 }, ...]
返回部分字段
如果只想选择实体的某些属性,可以使用以下语法:
const users = await getRepository(User)
.createQueryBuilder("user")
.select(["user.id", "user.name"])
.getMany();
这只会选择 User 的 id 和 name。
别名
我们使用 createQueryBuilder(“user”)但什么是"user"?它只是一个常规的 SQL 别名我们在任何地方都使用别名,除非我们处理选定的数据。createQueryBuilder(“user”) 相当于:
createQueryBuilder()
.select("user")
.from(User, "user");
// SELECT ... FROM users user
在这个 SQL 查询中,users 是表名,user 是我们分配给该表的别名。稍后我们使用此别名来访问表:
createQueryBuilder()
.select("user")
.from(User, "user")
.where("user.name = :name", { name: "Timber" });
// SELECT ... FROM users user WHERE user.name = 'Timber'
一个查询构建器不限于一个别名,它们可以有多个别名每个选择都可以有自己的别名,你可以选择多个有自己别名的表,你可以使用自己的别名连接多个表你也可以使用这些别名来访问选择的表(或正在选择的数据)。
隐藏列
如果要查询的模型具有"select:false"的列,则必须使用addSelect
函数来从列中检索信息。
假设你有以下实体:
import { Entity, PrimaryGeneratedColumn, Column } from "typeorm";
@Entity()
export class User {
@PrimaryGeneratedColumn()
id: number;
@Column()
name: string;
@Column({ select: false })
password: string;
}
使用标准的find
或查询,你将不会接收到模型的password
属性但是,如果执行以下操作:
const users = await connection
.getRepository(User)
.createQueryBuilder()
.select("user.id", "id")
.addSelect("user.password")
.getMany();
你将在查询中获得属性password
。
条件查询
我们使用了 where("user.name = :name", { name: "Timber" })
. {name:“Timber”}
代表什么?这是我们用来阻止 SQL 注入的参数我们可以写:where("user.name ='"+ name +"')
,但是这不安全,因为有可能被 SQL 注入安全的方法是使用这种特殊的语法:where("user.name =name",{name:"Timber"})
,其中 name
是参数名,值在对象中指定:{name:"Timber"}
。
.where("user.name = :name", { name: "Timber" })
// 是下面的简写
.where("user.name = :name")
.setParameter("name", "Timber")
注意:不要在查询构建器中为不同的值使用相同的参数名称。如果多次设置则后值将会把前面的覆盖。还可以提供一组值,并使用特殊的扩展语法将它们转换为 SQL 语句中的值列表:
.where("user.name IN (:...names)", { names: [ "Timber", "Cristal", "Lina" ] })
// WHERE user.name IN ('Timber', 'Cristal', 'Lina')
WHERE
添加 WHERE
表达式就像:
createQueryBuilder("user").where("user.name = :name", { name: "Timber" });
将会生成以下 SQL 语句:
SELECT ... FROM users user WHERE user.name = 'Timber'
你可以将 AND
添加到现有的 WHERE
表达式中:
createQueryBuilder("user")
.where("user.firstName = :firstName", { firstName: "Timber" })
.andWhere("user.lastName = :lastName", { lastName: "Saw" });
将会生成以下 SQL 语句:
SELECT ... FROM users user WHERE user.firstName = 'Timber' AND user.lastName = 'Saw'
你也可以添加 OR
添加到现有的 WHERE
表达式中:
createQueryBuilder("user")
.where("user.firstName = :firstName", { firstName: "Timber" })
.orWhere("user.lastName = :lastName", { lastName: "Saw" });
将会生成以下 SQL 语句:
SELECT ... FROM users user WHERE user.firstName = 'Timber' OR user.lastName = 'Saw'
你可以使用Brackets
将复杂的WHERE
表达式添加到现有的WHERE
中:
createQueryBuilder("user")
.where("user.registered = :registered", { registered: true })
.andWhere(new Brackets(qb => {
qb.where("user.firstName = :firstName", { firstName: "Timber" })
.orWhere("user.lastName = :lastName", { lastName: "Saw" })
将会生成以下 SQL 语句:
SELECT ... FROM users user WHERE user.registered = true AND (user.firstName = 'Timber' OR user.lastName = 'Saw')
你可以根据需要组合尽可能多的AND
和OR
表达式如果你多次使用.where
,你将覆盖所有以前的WHERE
表达式注意:小心orWhere
- 如果你使用带有AND
和OR
表达式的复杂表达式,请记住他们将无限制的叠加有时你只需要创建一个 where 字符串,避免使用orWhere
。
添加 HAVING 表达式
添加HAVING
表达式很简单:
createQueryBuilder("user").having("user.name = :name", { name: "Timber" });
将会生成以下 SQL 语句:
SELECT ... FROM users user HAVING user.name = 'Timber'
你可以添加 AND
到已经存在的 HAVING
表达式中:
createQueryBuilder("user")
.having("user.firstName = :firstName", { firstName: "Timber" })
.andHaving("user.lastName = :lastName", { lastName: "Saw" });
将会生成以下 SQL 语句:
SELECT ... FROM users user HAVING user.firstName = 'Timber' AND user.lastName = 'Saw'
你可以添加 OR
到已经存在的 HAVING
表达式中:
createQueryBuilder("user")
.having("user.firstName = :firstName", { firstName: "Timber" })
.orHaving("user.lastName = :lastName", { lastName: "Saw" });
将会生成以下 SQL 语句:
SELECT ... FROM users user HAVING user.firstName = 'Timber' OR user.lastName = 'Saw'
你可以根据需要组合尽可能多的AND
和OR
表达式如果使用多个.having
,后面的将覆盖所有之前的HAVING
表达式。
添加 ORDER BY 表达式
添加 ORDER BY
很简单:
createQueryBuilder("user").orderBy("user.id");
将会生成一下 SQL 语句:
SELECT ... FROM users user ORDER BY user.id
你可以将排序方向从升序更改为降序(或反之亦然):
createQueryBuilder("user").orderBy("user.id", "DESC");
createQueryBuilder("user").orderBy("user.id", "ASC");
也可以添加多个排序条件:
createQueryBuilder("user")
.orderBy("user.name")
.addOrderBy("user.id");
还可以使用排序字段作为一个 map:
createQueryBuilder("user").orderBy({
"user.name": "ASC",
"user.id": "DESC"
});
如果你使用了多个.orderBy
,后面的将覆盖所有之前的ORDER BY
表达式。
添加 GROUP BY 表达式
添加 GROUP BY
表达式很简单:
createQueryBuilder("user").groupBy("user.id");
将会生成以下 SQL 语句:
SELECT ... FROM users user GROUP BY user.id
如果要使用更多 group-by, 则可以使用 addGroupBy
:
createQueryBuilder("user")
.groupBy("user.name")
.addGroupBy("user.id");
如果使用了多个.groupBy
,则后面的将会覆盖之前所有的 ORDER BY
表达式。
添加 LIMIT 表达式
添加 LIMIT
表达式很简单:
createQueryBuilder("user").limit(10);
将会生成以下 SQL 语句:
SELECT ... FROM users user LIMIT 10
生成的 SQL 查询取决于数据库的类型(SQL,mySQL,Postgres 等)注意:如果你使用带有连接或子查询的复杂查询,LIMIT 可能无法正常工作如果使用分页,建议使用take
代替。
添加 OFFSET 表达式
添加 SQLOFFSET
表达式很简单:
createQueryBuilder("user").offset(10);
将会生成以下 SQL 语句:
SELECT ... FROM users user OFFSET 10
生成的 SQL 查询取决于数据库的类型(SQL,mySQL,Postgres 等)注意:如果你使用带有连接或子查询的复杂查询,OFFSET 可能无法正常工作如果使用分页,建议使用skip
代替。
联合查询
假设有以下实体:
import { Entity, PrimaryGeneratedColumn, Column, OneToMany } from "typeorm";
import { Photo } from "./Photo";
@Entity()
export class User {
@PrimaryGeneratedColumn()
id: number;
@Column()
name: string;
@OneToMany(
type => Photo,
photo => photo.user
)
photos: Photo[];
}
import { Entity, PrimaryGeneratedColumn, Column, ManyToOne } from "typeorm";
import { User } from "./User";
@Entity()
export class Photo {
@PrimaryGeneratedColumn()
id: number;
@Column()
url: string;
@ManyToOne(
type => User,
user => user.photos
)
user: User;
}
现在让我们假设你要用用户"Timber"加载他所有的 photos:
const user = await createQueryBuilder("user")
.leftJoinAndSelect("user.photos", "photo")
.where("user.name = :name", { name: "Timber" })
.getOne();
你将会得到以下结果:
{
id: 1,
name: "Timber",
photos: [{
id: 1,
url: "me-with-chakram.jpg"
}, {
id: 2,
url: "me-with-trees.jpg"
}]
}
你可以看到leftJoinAndSelect
自动加载了所有 Timber 的 photos 第一个参数是你要加载的关系,第二个参数是你为此关系的表分配的别名你可以在查询构建器中的任何位置使用此别名例如,让我们获得所有未删除的 Timber 的 photos。
const user = await createQueryBuilder("user")
.leftJoinAndSelect("user.photos", "photo")
.where("user.name = :name", { name: "Timber" })
.andWhere("photo.isRemoved = :isRemoved", { isRemoved: false })
.getOne();
将会生成以下 SQL 查询:
SELECT user.*, photo.* FROM users user
LEFT JOIN photos photo ON photo.user = user.id
WHERE user.name = 'Timber' AND photo.isRemoved = FALSE
你还可以向连接表达式添加条件,而不是使用"where":
const user = await createQueryBuilder("user")
.leftJoinAndSelect("user.photos", "photo", "photo.isRemoved = :isRemoved", {
isRemoved: false
})
.where("user.name = :name", { name: "Timber" })
.getOne();
这将生成以下 sql 查询:
SELECT user.*, photo.* FROM users user
LEFT JOIN photos photo ON photo.user = user.id AND photo.isRemoved = FALSE
WHERE user.name = 'Timber'
内联和左联
如果你想使用INNER JOIN
而不是LEFT JOIN
,只需使用innerJoinAndSelect
:
const user = await createQueryBuilder("user")
.innerJoinAndSelect("user.photos", "photo", "photo.isRemoved = :isRemoved", {
isRemoved: false
})
.where("user.name = :name", { name: "Timber" })
.getOne();
This will generate:
SELECT user.*, photo.* FROM users user
INNER JOIN photos photo ON photo.user = user.id AND photo.isRemoved = FALSE
WHERE user.name = 'Timber'
LEFT JOIN
和INNER JOIN
之间的区别在于,如果没有任何 photos,INNER JOIN
将不会返回 user 即使没有 photos,LEFT JOIN
也会返回 user 要了解有关不同连接类型的更多信息,请参阅 SQL 文档。你可以在不使用条件的情况下联查数据要做到这一点,使用leftJoin
或innerJoin
:
const user = await createQueryBuilder("user")
.innerJoin("user.photos", "photo")
.where("user.name = :name", { name: "Timber" })
.getOne();
将会生成如下 SQL 语句:
SELECT user.* FROM users user
INNER JOIN photos photo ON photo.user = user.id
WHERE user.name = 'Timber'
这将会返回 Timber 如果他有 photos,但是并不会返回他的 photos。
子查询
你可以轻松创建子查询FROM
,WHERE
和JOIN
表达式都支持子查询例如:
const qb = await getRepository(Post).createQueryBuilder("post");
const posts = qb
.where(
"post.title IN " +
qb
.subQuery()
.select("user.name")
.from(User, "user")
.where("user.registered = :registered")
.getQuery()
)
.setParameter("registered", true)
.getMany();
使用更优雅的方式来做同样的事情:
const posts = await connection
.getRepository(Post)
.createQueryBuilder("post")
.where(qb => {
const subQuery = qb
.subQuery()
.select("user.name")
.from(User, "user")
.where("user.registered = :registered")
.getQuery();
return "post.title IN " + subQuery;
})
.setParameter("registered", true)
.getMany();
或者,你可以创建单独的查询构建器并使用其生成的 SQL:
const userQb = await connection
.getRepository(User)
.createQueryBuilder("user")
.select("user.name")
.where("user.registered = :registered", { registered: true });
const posts = await connection
.getRepository(Post)
.createQueryBuilder("post")
.where("post.title IN (" + userQb.getQuery() + ")")
.setParameters(userQb.getParameters())
.getMany();
你可以在FROM
中创建子查询,如下所示:
const userQb = await connection
.getRepository(User)
.createQueryBuilder("user")
.select("user.name", "name")
.where("user.registered = :registered", { registered: true });
const posts = await connection
.createQueryBuilder()
.select("user.name", "name")
.from("(" + userQb.getQuery() + ")", "user")
.setParameters(userQb.getParameters())
.getRawMany();
或使用更优雅的语法:
const posts = await connection
.createQueryBuilder()
.select("user.name", "name")
.from(subQuery => {
return subQuery
.select("user.name", "name")
.from(User, "user")
.where("user.registered = :registered", { registered: true });
}, "user")
.getRawMany();
如果想添加一个子查询做为"second from",请使用addFrom
。你也可以在SELECT
语句中使用子查询:
const posts = await connection
.createQueryBuilder()
.select("post.id", "id")
.addSelect(subQuery => {
return subQuery
.select("user.name", "name")
.from(User, "user")
.limit(1);
}, "name")
.from(Post, "post")
.getRawMany();
分页
大多数情况下,在开发应用程序时,你可能需要分页功能如果你的应用程序中有分页,page slider 或无限滚动组件,则使用此选项。
const users = await getRepository(User)
.createQueryBuilder("user")
.leftJoinAndSelect("user.photos", "photo")
.take(10)
.getMany();
将会返回前 10 个 user 的 photos。
const users = await getRepository(User)
.createQueryBuilder("user")
.leftJoinAndSelect("user.photos", "photo")
.skip(10)
.getMany();
将返回除了前 10 个 user 以外的所有 user 的 photos。
你可以组合这些方法:
const users = await getRepository(User)
.createQueryBuilder("user")
.leftJoinAndSelect("user.photos", "photo")
.skip(5)
.take(10)
.getMany();
这将跳过前 5 个 users,并获取他们之后的 10 个 user。
take
和skip
可能看起来像我们正在使用limit
和offset
,但它们不是一旦你有更复杂的连接或子查询查询,limit
和offset
可能无法正常工作使用take
和skip
可以防止这些问题。
加锁
QueryBuilder 支持 optimistic 和 pessimistic 锁定要使用 pessimistic 读锁定,请使用以下方式:
const users = await getRepository(User)
.createQueryBuilder("user")
.setLock("pessimistic_read")
.getMany();
要使用 pessimistic 写锁定,请使用以下方式:
const users = await getRepository(User)
.createQueryBuilder("user")
.setLock("pessimistic_write")
.getMany();
要使用 optimistic 读锁定,请使用以下方式:
const users = await getRepository(User)
.createQueryBuilder("user")
.setLock("optimistic", existUser.version)
.getMany();
要使用 dirty 读锁定,请使用以下方式:
const users = await getRepository(User)
.createQueryBuilder("user")
.setLock("dirty_read")
.getMany();
Optimistic 锁定与@Version
和@UpdatedDate
装饰器一起使用。
与 Relations 结合
RelationQueryBuilder 是 QueryBuilder 的一种允许你使用关系来查询的特殊类型通过使用你可以在数据库中将实体彼此绑定,而无需加载任何实体,或者可以轻松地加载相关实体例如,我们有一个 Post 实体,它与 Category 有一个多对多的关系,叫做 categories 让我们为这种多对多关系添加一个新 category:
import { getConnection } from "typeorm";
await getConnection()
.createQueryBuilder()
.relation(Post, "categories")
.of(post)
.add(category);
这段代码相当于:
import { getManager } from "typeorm";
const postRepository = getRepository(Post);
const post = await postRepository.findOne(1, { relations: ["categories"] });
post.categories.push(category);
await postRepository.save(post);
但是这样使用第一种方式效率更高,因为它执行的操作数量最少,并且绑定数据库中的实体,这比每次都调用 save 这种笨重的方法简化了很多。此外,这种方法的另一个好处是不需要在 pushing 之前加载每个相关实体例如,如果你在一个 post 中有一万个 categories,那么在此列表中添加新 posts 可能会产生问题,因为执行此操作的标准方法是加载包含所有一万个 categories 的 post,push 一个新 category 然后保存这将会导致非常高的性能成本,而且基本上不适用于生产环境但是,使用 RelationQueryBuilder 则解决了这个问题。
此外,当进行绑定时,可以不需要使用实体,只需要使用实体 ID 即可例如,让我们在 id 为 1 的 post 中添加 id = 3 的 category:
import { getConnection } from "typeorm";
await getConnection()
.createQueryBuilder()
.relation(Post, "categories")
.of(1)
.add(3);
如果你使用了复合主键,则必须将它们作为 id 映射传递,例如:
import { getConnection } from "typeorm";
await getConnection()
.createQueryBuilder()
.relation(Post, "categories")
.of({ firstPostId: 1, secondPostId: 3 })
.add({ firstCategoryId: 2, secondCategoryId: 4 });
也可以按照添加实体的方式删除实体:
import { getConnection } from "typeorm";
// 此代码从给定的post中删除一个category
await getConnection()
.createQueryBuilder()
.relation(Post, "categories")
.of(post) // 也可以使用post id
.remove(category); // 也可以只使用category ID
添加和删除相关实体针对多对多
和一对多
关系对于一对一
和多对一
关系,请使用set
代替:
import { getConnection } from "typeorm";
// 此代码set给定post的category
await getConnection()
.createQueryBuilder()
.relation(Post, "categories")
.of(post) // 也可以使用post id
.set(category); // 也可以只使用category ID
如果要取消设置关系(将其设置为 null),只需将null
传递给set
方法:
import { getConnection } from "typeorm";
// 此代码取消设置给定post的category
await getConnection()
.createQueryBuilder()
.relation(Post, "categories")
.of(post) // 也可以使用post id
.set(null);
除了更新关系外,关系查询构建器还允许你加载关系实体例如,假设在Post
实体内部,我们有多对多的categories
关系和多对一的user
关系,为加载这些关系,你可以使用以下代码:
import { getConnection } from "typeorm";
const post = await getConnection().manager.findOne(Post, 1);
post.categories = await getConnection()
.createQueryBuilder()
.relation(Post, "categories")
.of(post) // 也可以使用post id
.loadMany();
post.author = await getConnection()
.createQueryBuilder()
.relation(User, "user")
.of(post) // 也可以使用post id
.loadOne();