@@ -24,6 +24,7 @@ extension _FluentPostgresDatabase: Database {
24
24
default : break
25
25
}
26
26
let ( sql, binds) = self . serialize ( expression)
27
+ self . logger. debug ( " \( sql) \( binds) " )
27
28
do {
28
29
return try self . query ( sql, binds. map { try self . encoder. encode ( $0) } ) {
29
30
onOutput ( $0. databaseOutput ( using: self . decoder) )
@@ -37,6 +38,7 @@ extension _FluentPostgresDatabase: Database {
37
38
let expression = SQLSchemaConverter ( delegate: PostgresConverterDelegate ( ) )
38
39
. convert ( schema)
39
40
let ( sql, binds) = self . serialize ( expression)
41
+ self . logger. debug ( " \( sql) \( binds) " )
40
42
do {
41
43
return try self . query ( sql, binds. map { try self . encoder. encode ( $0) } ) {
42
44
fatalError ( " unexpected row: \( $0) " )
@@ -53,6 +55,7 @@ extension _FluentPostgresDatabase: Database {
53
55
for c in e. createCases {
54
56
_ = builder. value ( c)
55
57
}
58
+ self . logger. debug ( " \( builder. query) " )
56
59
return builder. run ( )
57
60
case . update:
58
61
if !e. deleteCases. isEmpty {
@@ -65,9 +68,12 @@ extension _FluentPostgresDatabase: Database {
65
68
for create in e. createCases {
66
69
_ = builder. add ( value: create)
67
70
}
71
+ self . logger. debug ( " \( builder. query) " )
68
72
return builder. run ( )
69
73
case . delete:
70
- return self . sql ( ) . drop ( enum: e. name) . run ( )
74
+ let builder = self . sql ( ) . drop ( enum: e. name)
75
+ self . logger. debug ( " \( builder. query) " )
76
+ return builder. run ( )
71
77
}
72
78
}
73
79
@@ -76,7 +82,8 @@ extension _FluentPostgresDatabase: Database {
76
82
return closure ( self )
77
83
}
78
84
return self . database. withConnection { conn in
79
- conn. simpleQuery ( " BEGIN " ) . flatMap { _ in
85
+ self . logger. debug ( " BEGIN " )
86
+ return conn. simpleQuery ( " BEGIN " ) . flatMap { _ in
80
87
let db = _FluentPostgresDatabase (
81
88
database: conn,
82
89
context: self . context,
@@ -85,11 +92,13 @@ extension _FluentPostgresDatabase: Database {
85
92
inTransaction: true
86
93
)
87
94
return closure ( db) . flatMap { result in
88
- conn. simpleQuery ( " COMMIT " ) . map { _ in
95
+ self . logger. debug ( " COMMIT " )
96
+ return conn. simpleQuery ( " COMMIT " ) . map { _ in
89
97
result
90
98
}
91
99
} . flatMapError { error in
92
- conn. simpleQuery ( " ROLLBACK " ) . flatMapThrowing { _ in
100
+ self . logger. debug ( " ROLLBACK " )
101
+ return conn. simpleQuery ( " ROLLBACK " ) . flatMapThrowing { _ in
93
102
throw error
94
103
}
95
104
}
0 commit comments