diff --git a/lib/www/server/lib/db/connection.js b/lib/www/server/lib/db/connection.js
index adf4d21..3cf4d5c 100644
--- a/lib/www/server/lib/db/connection.js
+++ b/lib/www/server/lib/db/connection.js
@@ -28,7 +28,16 @@ const transaction = {
 	}
 };
 
+async function setSurvey (projectId, client) {
+	if (!client) {
+		client = await pool.connect();
+	}
+	await client.query("CALL set_survey($1);", [projectId]);
+	return client;
+}
+
 module.exports = {
 	pool,
 	transaction,
+	setSurvey
 };