test: transaction ddl

Signed-off-by: usamoi <usamoi@outlook.com>

.github/workflows/check.yml

@@ -84,20 +84,11 @@ jobs:
           cargo test --all --no-fail-fast --no-default-features --features "pg${{ matrix.version }} pg_test" --target x86_64-unknown-linux-gnu -- --nocapture
       - name: Install release
         run: ./scripts/ci_install.sh
-      - name: Sqllogictest
-        run: |
-          psql -f ./tests/init.sql
-          sqllogictest -u runner -d runner './tests/sqllogictest/*.slt'
       - uses: actions/setup-python@v5
         with:
-          python-version: '3.10' 
-      - name: Crash Recovery test
-        run: |
-          sudo pip install psutil==5.9.7
-          psql -f ./tests/init.sql
-          sqllogictest -u runner -d runner './tests/crash/create.slt'
-          sudo python ./tests/crash/kill.py
-          sqllogictest -u runner -d runner './tests/crash/restore.slt'
+          python-version: "3.10"
+      - name: Test 2
+        run: ./tests/tests.sh
       - uses: actions/cache/save@v3
         with:
           path: |

tests/crash/test.sh

@@ -0,0 +1,7 @@
+#!/usr/bin/env bash
+set -e
+
+sudo pip install psutil==5.9.7
+sqllogictest -u runner -d runner $(dirname $0)/create.slt
+sudo python $(dirname $0)/kill.py
+sqllogictest -u runner -d runner $(dirname $0)/restore.slt

tests/init.sql

@@ -1,3 +1 @@
-DROP EXTENSION IF EXISTS vectors CASCADE;
 CREATE EXTENSION vectors;
-DROP TABLE IF EXISTS t;

tests/sqllogictest/error.slt

@@ -1,5 +1,5 @@
 statement ok
-DROP TABLE IF EXISTS t;
+SET search_path TO pg_temp, vectors;
 
 statement ok
 CREATE TABLE t (val vector(3));

tests/sqllogictest/flat.slt

@@ -1,5 +1,5 @@
 statement ok
-DROP TABLE IF EXISTS t;
+SET search_path TO pg_temp, vectors;
 
 statement ok
 CREATE TABLE t (val vector(3));

tests/sqllogictest/fp16.slt

@@ -1,5 +1,5 @@
 statement ok
-DROP TABLE IF EXISTS t;
+SET search_path TO pg_temp, vectors;
 
 statement ok
 CREATE TABLE t (val vecf16(3));

tests/sqllogictest/hnsw.slt

@@ -1,5 +1,5 @@
 statement ok
-DROP TABLE IF EXISTS t;
+SET search_path TO pg_temp, vectors;
 
 statement ok
 CREATE TABLE t (val vector(3));

tests/sqllogictest/index.slt

@@ -1,5 +1,5 @@
 statement ok
-DROP TABLE IF EXISTS t;
+SET search_path TO pg_temp, vectors;
 
 statement ok
 CREATE TABLE t (val vector(3));

tests/sqllogictest/ivf.slt

@@ -1,9 +1,5 @@
 statement ok
-DROP TABLE IF EXISTS t;
-
-# ivf native
-statement ok
-DROP TABLE IF EXISTS t;
+SET search_path TO pg_temp, vectors;
 
 statement ok
 CREATE TABLE t (val vector(3));
@@ -38,7 +34,7 @@ DROP TABLE t;
 
 # ivfpq
 statement ok
-DROP TABLE IF EXISTS t;
+DROP TABLE t;
 
 statement ok
 CREATE TABLE t (val vector(3));

tests/sqllogictest/partition.slt

@@ -1,5 +1,5 @@
 statement ok
-DROP TABLE IF EXISTS items;
+SET search_path TO pg_temp, vectors;
 
 # partition table
 statement ok

tests/sqllogictest/quantization.slt

@@ -1,5 +1,5 @@
 statement ok
-DROP TABLE IF EXISTS t;
+SET search_path TO pg_temp, vectors;
 
 # product quantization
 statement ok

tests/sqllogictest/reindex.slt

@@ -1,5 +1,5 @@
 statement ok
-DROP TABLE IF EXISTS t;
+SET search_path TO pg_temp, vectors;
 
 statement ok
 CREATE TABLE t (val vector(3));

tests/sqllogictest/test.sh

@@ -0,0 +1,4 @@
+#!/usr/bin/env bash
+set -e
+
+sqllogictest -u runner -d runner $(dirname $0)/*.slt

tests/sqllogictest/update.slt

@@ -1,5 +1,5 @@
 statement ok
-DROP TABLE IF EXISTS t;
+SET search_path TO pg_temp, vectors;
 
 statement ok
 CREATE TABLE t (val vector(3));

tests/sqllogictest/vbase.slt

@@ -1,5 +1,5 @@
 statement ok
-DROP TABLE IF EXISTS t;
+SET search_path TO pg_temp, vectors;
 
 statement ok
 CREATE TABLE t (val vector(3));

tests/tests.sh

@@ -0,0 +1,8 @@
+#!/usr/bin/env bash
+set -e
+
+psql -f $(dirname $0)/init.sql
+
+for x in $(dirname $0)/*/test.sh; do
+    $x
+done

tests/transaction/test.sh

@@ -0,0 +1,23 @@
+#!/usr/bin/env bash
+set -e
+
+d=$(psql -U postgres -tAqX -c "SELECT CURRENT_SETTING('data_directory')")/pg_vectors/indexes
+
+a=$(sudo ls -l $d | wc -l)
+
+printf "entries = $a\n" 
+
+psql -f $(dirname $0)/test.sql
+
+sleep 1
+
+b=$(sudo ls -l $d | wc -l)
+
+printf "entries = $b\n" 
+
+if [ "$a" == "$b" ]; then
+    echo "Transaction test [OK]"
+else
+    echo "Transaction test [FAILED]"
+    exit 1
+fi

tests/transaction/test.sql

@@ -0,0 +1,7 @@
+CREATE TABLE tests_transaction_t(val vector(3));
+
+INSERT INTO tests_transaction_t (val) SELECT ARRAY[random(), random(), random()]::real[] FROM generate_series(1, 1000);
+
+BEGIN;
+CREATE INDEX ON t USING vectors (val vector_l2_ops);
+ABORT;