Changeset: 56b456a91840 for MonetDB
URL: https://dev.monetdb.org/hg/MonetDB/rev/56b456a91840
Added Files:
sql/test/miscellaneous/Tests/unlogged.py
Modified Files:
sql/test/miscellaneous/Tests/All
Branch: unlogged
Log Message:
Add tests for UNLOGGED TABLE.
diffs (99 lines):
diff --git a/sql/test/miscellaneous/Tests/All b/sql/test/miscellaneous/Tests/All
--- a/sql/test/miscellaneous/Tests/All
+++ b/sql/test/miscellaneous/Tests/All
@@ -1,3 +1,4 @@
+unlogged
column_aliases
declared_tables
trace_test
diff --git a/sql/test/miscellaneous/Tests/unlogged.py
b/sql/test/miscellaneous/Tests/unlogged.py
new file mode 100644
--- /dev/null
+++ b/sql/test/miscellaneous/Tests/unlogged.py
@@ -0,0 +1,86 @@
+import os, sys, tempfile, pymonetdb
+
+try:
+ from MonetDBtesting import process
+except ImportError:
+ import process
+
+with tempfile.TemporaryDirectory() as farm_dir:
+ os.mkdir(os.path.join(farm_dir, 'node1'))
+
+ with process.server(
+ dbname='node1',
+ dbfarm=os.path.join(farm_dir, 'node1'),
+ stdin=process.PIPE,
+ stdout=process.PIPE,
+ stderr=process.PIPE,
+ mapiport='0') as node1_proc:
+ node1_conn = pymonetdb.connect(database='node1',
port=node1_proc.dbport, autocommit=True)
+ node1_cur = node1_conn.cursor()
+
+ node1_cur.execute("CREATE unlogged TABLE foo (i INT)")
+ if node1_cur.execute("INSERT INTO foo VALUES (10), (20)") != 2:
+ sys.stderr.write("2 rows inserted expected")
+ if node1_cur.execute("UPDATE foo set i = i + 20 WHERE i = 10") !=
1:
+ sys.stderr.write("1 rows updated expected")
+ node1_cur.execute("SELECT i FROM foo ORDER BY i")
+ if node1_cur.fetchall() != [(20,), (30,)]:
+ sys.stderr.write("[(20), (30)] expected")
+ node1_cur.close()
+ node1_conn.close()
+
+ with process.server(
+ dbname='node1',
+ dbfarm=os.path.join(farm_dir, 'node1'),
+ stdin=process.PIPE,
+ stdout=process.PIPE,
+ stderr=process.PIPE,
+ mapiport='0') as node1_proc:
+ node1_conn = pymonetdb.connect(database='node1',
port=node1_proc.dbport, autocommit=True)
+ node1_cur = node1_conn.cursor()
+
+ node1_cur.execute("SELECT i FROM foo ORDER BY i")
+ if node1_cur.fetchall() != []:
+ sys.stderr.write("[] expected")
+ node1_cur.close()
+ node1_conn.close()
+
+with tempfile.TemporaryDirectory() as farm_dir:
+ os.mkdir(os.path.join(farm_dir, 'node1'))
+
+ with process.server(
+ dbname='node1',
+ dbfarm=os.path.join(farm_dir, 'node1'),
+ stdin=process.PIPE,
+ stdout=process.PIPE,
+ stderr=process.PIPE,
+ mapiport='0') as node1_proc:
+ node1_conn = pymonetdb.connect(database='node1',
port=node1_proc.dbport, autocommit=True)
+ node1_cur = node1_conn.cursor()
+
+ node1_cur.execute("CREATE unlogged TABLE foo (i) AS VALUES (10),
(20)")
+ if node1_cur.execute("INSERT INTO foo VALUES (30), (40)") != 2:
+ sys.stderr.write("2 rows inserted expected")
+ if node1_cur.execute("UPDATE foo set i = 50 WHERE i = 10") != 1:
+ sys.stderr.write("1 rows updated expected")
+ node1_cur.execute("SELECT i FROM foo ORDER BY i")
+ if node1_cur.fetchall() != [(20,), (30,), (40,), (50,)]:
+ sys.stderr.write("[(20), (30), (40), (50)] expected")
+ node1_cur.close()
+ node1_conn.close()
+
+ with process.server(
+ dbname='node1',
+ dbfarm=os.path.join(farm_dir, 'node1'),
+ stdin=process.PIPE,
+ stdout=process.PIPE,
+ stderr=process.PIPE,
+ mapiport='0') as node1_proc:
+ node1_conn = pymonetdb.connect(database='node1',
port=node1_proc.dbport, autocommit=True)
+ node1_cur = node1_conn.cursor()
+
+ node1_cur.execute("SELECT i FROM foo ORDER BY i")
+ if node1_cur.fetchall() != [(10,), (20,)]:
+ sys.stderr.write("[(10), (20)] expected")
+ node1_cur.close()
+ node1_conn.close()
_______________________________________________
checkin-list mailing list -- [email protected]
To unsubscribe send an email to [email protected]
