Make query logging optional

src/config/database.js

@@ -13,6 +13,7 @@ if (url) {
 		username: connectionUrl.username,
 		password: connectionUrl.password,
 		port: connectionUrl.port,
+		log_queries: env('LOG_SQL_QUERIES', 'true') === 'true',
 	}
 } else {
 	module.exports = {
@@ -28,6 +29,7 @@ if (url) {
 				ca: Buffer.from(env('DATABASE_CA_CERT', null) ?? '', 'base64').toString(),
 			}
 		},
+		log_queries: env('LOG_SQL_QUERIES', 'true') === 'true',
 	}
 }
 

src/database/models/index.js

@@ -41,28 +41,30 @@ Object.keys(db).forEach(modelName => {
 	}
 })
 
-sequelize.addHook('beforeQuery', (model, query) => {
-	const trace = threadContext.get('profiling')
-	if (trace) {
-		const traceId = uuid()
-		const span = trace.startChild({
-			op: 'sql.query',
-		})
-		threadContext.set(`span_${ traceId }`, span)
-		query.options.trace = traceId
-	}
-})
-
-sequelize.addHook('afterQuery', (model, query) => {
-	if (query.options.trace) {
-		const trace = threadContext.get(`span_${ query.options.trace }`)
+if (config('database.log_queries')) {
+	sequelize.addHook('beforeQuery', (model, query) => {
+		const trace = threadContext.get('profiling')
 		if (trace) {
-			trace.description = query.sql
-			trace.setData('sql.params', query.options.bind)
-			trace.finish()
+			const traceId = uuid()
+			const span = trace.startChild({
+				op: 'sql.query',
+			})
+			threadContext.set(`span_${ traceId }`, span)
+			query.options.trace = traceId
 		}
-	}
-})
+	})
+
+	sequelize.addHook('afterQuery', (model, query) => {
+		if (query.options.trace) {
+			const trace = threadContext.get(`span_${ query.options.trace }`)
+			if (trace) {
+				trace.description = query.sql
+				trace.setData('sql.params', query.options.bind)
+				trace.finish()
+			}
+		}
+	})
+}
 
 db.sequelize = sequelize
 db.Sequelize = Sequelize