+
+
+def test_execute_file_with_pre_code(dsn, tmp_path, temp_db_cursor):
+ tmpfile = tmp_path / 'test.sql'
+ tmpfile.write_text('INSERT INTO test VALUES(4)')
+
+ db_utils.execute_file(dsn, tmpfile, pre_code='CREATE TABLE test (id INT)')
+
+ temp_db_cursor.execute('SELECT * FROM test')
+
+ assert temp_db_cursor.rowcount == 1
+ assert temp_db_cursor.fetchone()[0] == 4
+
+
+def test_execute_file_with_post_code(dsn, tmp_path, temp_db_cursor):
+ tmpfile = tmp_path / 'test.sql'
+ tmpfile.write_text('CREATE TABLE test (id INT)')
+
+ db_utils.execute_file(dsn, tmpfile, post_code='INSERT INTO test VALUES(23)')
+
+ temp_db_cursor.execute('SELECT * FROM test')
+
+ assert temp_db_cursor.rowcount == 1
+ assert temp_db_cursor.fetchone()[0] == 23