Skip to content

Commit bdc5de0

Browse files
w3b6x9soedirgo
authored andcommitted
feat: add tg_rel_id to trigger return
1 parent b0a0bff commit bdc5de0

File tree

4 files changed

+7
-1
lines changed

4 files changed

+7
-1
lines changed

src/lib/PostgresMetaTriggers.ts

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -130,7 +130,9 @@ export default class PostgresMetaTriggers {
130130
const triggerCondition = condition ? `WHEN (${condition})` : ''
131131
const functionArgs = `${function_args?.map(literal).join(',') ?? ''}`
132132

133-
const sql = `CREATE TRIGGER ${ident(name)} ${activation} ${triggerEvents} ON ${qualifiedTableName} ${triggerOrientation} ${triggerCondition} EXECUTE FUNCTION ${qualifiedFunctionName}(${functionArgs});`
133+
const sql = `CREATE TRIGGER ${ident(
134+
name
135+
)} ${activation} ${triggerEvents} ON ${qualifiedTableName} ${triggerOrientation} ${triggerCondition} EXECUTE FUNCTION ${qualifiedFunctionName}(${functionArgs});`
134136

135137
const { error } = await this.query(sql)
136138

src/lib/sql/triggers.sql

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
SELECT
22
pg_t.oid AS id,
3+
pg_t.tgrelid AS table_id,
34
CASE
45
WHEN pg_t.tgenabled = 'D' THEN 'DISABLED'
56
WHEN pg_t.tgenabled = 'O' THEN 'ORIGIN'
@@ -34,6 +35,7 @@ JOIN pg_namespace AS pg_n
3435
ON pg_p.pronamespace = pg_n.oid
3536
GROUP BY
3637
pg_t.oid,
38+
pg_t.tgrelid,
3739
pg_t.tgenabled,
3840
pg_t.tgargs,
3941
pg_t.tgnargs,

src/lib/types.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -234,6 +234,7 @@ export type PostgresTable = Static<typeof postgresTableSchema>
234234

235235
export const postgresTriggerSchema = Type.Object({
236236
id: Type.Integer(),
237+
table_id: Type.Integer(),
237238
enabled_mode: Type.Union([
238239
Type.Literal('ORIGIN'),
239240
Type.Literal('REPLICA'),

test/integration/index.spec.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -933,6 +933,7 @@ describe('/triggers', () => {
933933
const { data: triggerRecord } = await axios.post(`${URL}/triggers`, trigger)
934934

935935
assert.strictEqual(typeof triggerRecord.id, 'number')
936+
assert.strictEqual(typeof triggerRecord.table_id, 'number')
936937
assert.strictEqual(triggerRecord.enabled_mode, 'ORIGIN')
937938
assert.strictEqual(triggerRecord.name, 'test_trigger')
938939
assert.strictEqual(triggerRecord.table, 'users_audit')

0 commit comments

Comments
 (0)