Skip to content

Commit 5b2fd72

Browse files
committed
Change the table repository to use the post processor for table names
1 parent 0496d04 commit 5b2fd72

File tree

2 files changed

+8
-8
lines changed

2 files changed

+8
-8
lines changed

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "strontium",
3-
"version": "2.6.0",
3+
"version": "2.6.1",
44
"description": "Strontium is a TypeScript toolkit for High Performance API servers built for Production not Projects.",
55
"main": "lib/src/index.js",
66
"types": "lib/src/index.d.ts",

src/query/drivers/sql/TableRepository.ts

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -116,13 +116,13 @@ export abstract class TableRepository<
116116
connection: SQLStore = this.store
117117
): Promise<Array<T>> {
118118
let [filterQuery, filterParameters] = compileSQLFilter(filter)
119-
let parameters = [...filterParameters]
119+
let parameters = [this.tableName, ...filterParameters]
120120

121121
let lookupQuery = `
122122
SELECT
123123
${this.queryFields.join(", ")}
124124
FROM
125-
"${this.tableName}"
125+
??
126126
${filterQuery !== "" ? "WHERE" : ""}
127127
${filterQuery}
128128
`
@@ -165,11 +165,11 @@ export abstract class TableRepository<
165165

166166
let lookupQuery = `
167167
UPDATE
168-
"${this.tableName}"
168+
??
169169
SET
170170
${Object.keys(filteredPayload).map(() => "?? = ?")}
171171
${filterQuery !== "" ? "WHERE" : ""}
172-
${filterQuery}
172+
${filterQuery}
173173
`
174174

175175
let payloadParameters: Array<any> = []
@@ -180,7 +180,7 @@ export abstract class TableRepository<
180180

181181
let [processedQuery, processedParameters] = this.postProcessor(
182182
lookupQuery,
183-
[...payloadParameters, ...filterParameters]
183+
[this.tableName, ...payloadParameters, ...filterParameters]
184184
)
185185
await connection.query(processedQuery, processedParameters)
186186
}
@@ -190,11 +190,11 @@ export abstract class TableRepository<
190190
connection: SQLStore = this.store
191191
): Promise<void> {
192192
let [filterQuery, filterParameters] = compileSQLFilter(filter)
193-
let parameters = [...filterParameters]
193+
let parameters = [this.tableName, ...filterParameters]
194194

195195
let lookupQuery = `
196196
DELETE FROM
197-
"${this.tableName}"
197+
??
198198
${filterQuery !== "" ? "WHERE" : ""}
199199
${filterQuery}
200200
`

0 commit comments

Comments
 (0)