feature/#41-query-builder-sorting #87
2 changed files with 34 additions and 17 deletions
|
@ -62,11 +62,17 @@ export default abstract class DynamicQueryBuilder {
|
||||||
count?: number;
|
count?: number;
|
||||||
noLimit?: boolean;
|
noLimit?: boolean;
|
||||||
}): SelectQueryBuilder<ObjectLiteral> {
|
}): SelectQueryBuilder<ObjectLiteral> {
|
||||||
let affix = Math.random().toString(36).substring(2);
|
let affix = queryObj.id;
|
||||||
let query = dataSource.getRepository(queryObj.table).createQueryBuilder(`${queryObj.table}_${affix}`);
|
let query = dataSource.getRepository(queryObj.table).createQueryBuilder(`${affix}_${queryObj.table}`);
|
||||||
|
|
||||||
this.buildDynamicQuery(query, queryObj, affix);
|
this.buildDynamicQuery(query, queryObj, affix);
|
||||||
|
|
||||||
|
if (queryObj.orderBy) {
|
||||||
|
queryObj.orderBy.forEach((order) => {
|
||||||
|
query.addOrderBy(`${order.id}_${order.table}.${order.column}`, order.order);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
if (!noLimit) {
|
if (!noLimit) {
|
||||||
query.offset(offset);
|
query.offset(offset);
|
||||||
query.limit(count);
|
query.limit(count);
|
||||||
|
@ -78,10 +84,10 @@ export default abstract class DynamicQueryBuilder {
|
||||||
private static buildDynamicQuery(
|
private static buildDynamicQuery(
|
||||||
query: SelectQueryBuilder<ObjectLiteral>,
|
query: SelectQueryBuilder<ObjectLiteral>,
|
||||||
queryObject: DynamicQueryStructure,
|
queryObject: DynamicQueryStructure,
|
||||||
affix: string = "",
|
affix: string = "", // table id
|
||||||
depth: number = 0
|
depth: number = 0
|
||||||
): void {
|
): void {
|
||||||
const alias = queryObject.table + "_" + affix;
|
const alias = `${affix}_${queryObject.table}`;
|
||||||
let firstSelect = true;
|
let firstSelect = true;
|
||||||
let selects: Array<string> = [];
|
let selects: Array<string> = [];
|
||||||
|
|
||||||
|
@ -108,18 +114,12 @@ export default abstract class DynamicQueryBuilder {
|
||||||
|
|
||||||
if (queryObject.join) {
|
if (queryObject.join) {
|
||||||
for (const join of queryObject.join) {
|
for (const join of queryObject.join) {
|
||||||
let subaffix = Math.random().toString(36).substring(2);
|
let subaffix = join.id;
|
||||||
query.leftJoin(`${alias}.${join.foreignColumn}`, join.table + "_" + subaffix);
|
query.leftJoin(`${alias}.${join.foreignColumn}`, `${subaffix}_${join.table}`);
|
||||||
|
|
||||||
this.buildDynamicQuery(query, join, subaffix, depth + 1);
|
this.buildDynamicQuery(query, join, subaffix, depth + 1);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (queryObject.orderBy) {
|
|
||||||
queryObject.orderBy.forEach((order) => {
|
|
||||||
query.addOrderBy(`${alias}.${order.column}`, order.order);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public static applyWhere(
|
public static applyWhere(
|
||||||
|
@ -391,19 +391,22 @@ export default abstract class DynamicQueryBuilder {
|
||||||
}
|
}
|
||||||
|
|
||||||
const memberQuery: DynamicQueryStructure = {
|
const memberQuery: DynamicQueryStructure = {
|
||||||
|
id: "memberId",
|
||||||
select: "*",
|
select: "*",
|
||||||
table: "member",
|
table: "member",
|
||||||
orderBy: [
|
orderBy: [
|
||||||
{ column: "lastname", order: "ASC" },
|
{ id: "memberId", depth: 0, table: "member", column: "lastname", order: "ASC" },
|
||||||
{ column: "firstname", order: "ASC" },
|
{ id: "memberId", depth: 0, table: "member", column: "firstname", order: "ASC" },
|
||||||
],
|
],
|
||||||
};
|
};
|
||||||
|
|
||||||
const memberByRunningMembershipQuery: DynamicQueryStructure = {
|
const memberByRunningMembershipQuery: DynamicQueryStructure = {
|
||||||
|
id: "memberId",
|
||||||
select: "*",
|
select: "*",
|
||||||
table: "member",
|
table: "member",
|
||||||
join: [
|
join: [
|
||||||
{
|
{
|
||||||
|
id: "membershipId",
|
||||||
select: "*",
|
select: "*",
|
||||||
table: "membership",
|
table: "membership",
|
||||||
where: [{ structureType: "condition", concat: "_", operation: "null", column: "end", value: "" }],
|
where: [{ structureType: "condition", concat: "_", operation: "null", column: "end", value: "" }],
|
||||||
|
@ -411,7 +414,7 @@ const memberByRunningMembershipQuery: DynamicQueryStructure = {
|
||||||
},
|
},
|
||||||
],
|
],
|
||||||
orderBy: [
|
orderBy: [
|
||||||
{ column: "lastname", order: "ASC" },
|
{ id: "memberId", depth: 0, table: "member", column: "lastname", order: "ASC" },
|
||||||
{ column: "firstname", order: "ASC" },
|
{ id: "memberId", depth: 0, table: "member", column: "firstname", order: "ASC" },
|
||||||
],
|
],
|
||||||
};
|
};
|
||||||
|
|
|
@ -1,9 +1,10 @@
|
||||||
export interface DynamicQueryStructure {
|
export interface DynamicQueryStructure {
|
||||||
|
id: string;
|
||||||
select: string[] | "*";
|
select: string[] | "*";
|
||||||
table: string;
|
table: string;
|
||||||
where?: Array<ConditionStructure>;
|
where?: Array<ConditionStructure>;
|
||||||
join?: Array<DynamicQueryStructure & { foreignColumn: string }>;
|
join?: Array<DynamicQueryStructure & { foreignColumn: string }>;
|
||||||
orderBy?: Array<OrderByStructure>;
|
orderBy?: Array<OrderByStructure>; // only at top level
|
||||||
}
|
}
|
||||||
|
|
||||||
export type ConditionStructure = (
|
export type ConditionStructure = (
|
||||||
|
@ -48,6 +49,9 @@ export type WhereOperation =
|
||||||
// TODO: age between | age equals | age greater | age smaller
|
// TODO: age between | age equals | age greater | age smaller
|
||||||
|
|
||||||
export type OrderByStructure = {
|
export type OrderByStructure = {
|
||||||
|
id: string;
|
||||||
|
depth: number;
|
||||||
|
table: string;
|
||||||
column: string;
|
column: string;
|
||||||
order: OrderByType;
|
order: OrderByType;
|
||||||
};
|
};
|
||||||
|
@ -59,6 +63,7 @@ export type QueryResult = {
|
||||||
};
|
};
|
||||||
|
|
||||||
export const exampleQuery: DynamicQueryStructure = {
|
export const exampleQuery: DynamicQueryStructure = {
|
||||||
|
id: "1234",
|
||||||
select: ["firstname", "lastname"],
|
select: ["firstname", "lastname"],
|
||||||
table: "member",
|
table: "member",
|
||||||
where: [
|
where: [
|
||||||
|
@ -92,16 +97,19 @@ export const exampleQuery: DynamicQueryStructure = {
|
||||||
],
|
],
|
||||||
join: [
|
join: [
|
||||||
{
|
{
|
||||||
|
id: "5678",
|
||||||
select: "*",
|
select: "*",
|
||||||
table: "communication",
|
table: "communication",
|
||||||
foreignColumn: "sendNewsletter",
|
foreignColumn: "sendNewsletter",
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
|
id: "91011",
|
||||||
select: "*",
|
select: "*",
|
||||||
table: "membership",
|
table: "membership",
|
||||||
foreignColumn: "memberships",
|
foreignColumn: "memberships",
|
||||||
join: [
|
join: [
|
||||||
{
|
{
|
||||||
|
id: "121314",
|
||||||
select: "*",
|
select: "*",
|
||||||
table: "membership_status",
|
table: "membership_status",
|
||||||
foreignColumn: "status",
|
foreignColumn: "status",
|
||||||
|
@ -120,10 +128,16 @@ export const exampleQuery: DynamicQueryStructure = {
|
||||||
],
|
],
|
||||||
orderBy: [
|
orderBy: [
|
||||||
{
|
{
|
||||||
|
id: "1234",
|
||||||
|
depth: 0,
|
||||||
|
table: "member",
|
||||||
column: "firstname",
|
column: "firstname",
|
||||||
order: "ASC",
|
order: "ASC",
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
|
id: "1234",
|
||||||
|
depth: 0,
|
||||||
|
table: "member",
|
||||||
column: "lastname",
|
column: "lastname",
|
||||||
order: "ASC",
|
order: "ASC",
|
||||||
},
|
},
|
||||||
|
|
Loading…
Add table
Reference in a new issue