Switch sqlalchemy-cratedb from dev branch to released 0.43.1 (#1867)

* Update sqlalchemy-cratedb requirement to >=0.43.1 and adjust test skips for async dialects

* skip for unsupported psycopg dialect

* Update insert_records value with CrateDB statement length limit

* Update insert_records

Author: bgunebakan

by-dataframe/pandas/requirements.txt

@@ -3,4 +3,4 @@ colorlog<7
 crate>=2.1.2
 pandas>=2.3,<3.1
 pueblo>=0.0.18
-sqlalchemy-cratedb[all] @ git+https://github.com/crate-workbench/sqlalchemy-cratedb@amo/postgresql-async
+sqlalchemy-cratedb[all]>=0.43.1

by-dataframe/pandas/test_read.py

@@ -1,16 +1,19 @@
 import shlex
 import subprocess
+import pytest
 
 
 def run(command: str):
     subprocess.check_call(shlex.split(command))
 
 
 def test_read_urllib3():
-    cmd = "time python read_pandas.py --dburi=crate+urllib3://crate@localhost:4200"
+    cmd = "time python read_pandas.py --dburi=crate://crate@localhost:4200"
     run(cmd)
 
 
+# TODO: Remove skip when psycopg dialect is released in sqlalchemy-cratedb
+@pytest.mark.skip(reason="psycopg dialect not yet in released sqlalchemy-cratedb")
 def test_read_psycopg3():
     cmd = "time python read_pandas.py --dburi=crate+psycopg://crate@localhost:5432"
     run(cmd)

by-language/python-sqlalchemy/requirements.txt

@@ -3,4 +3,4 @@ colorlog<7
 crate>=2.1.2
 pueblo>=0.0.18
 sqlalchemy>=2.0.49,<2.1
-sqlalchemy-cratedb[all] @ git+https://github.com/crate-workbench/sqlalchemy-cratedb@amo/postgresql-async
+sqlalchemy-cratedb[all]>=0.43.1

by-language/python-sqlalchemy/test.py

@@ -8,13 +8,14 @@ def run(command: str):
 
 
 def test_insert_efficient_multirow():
-    insert_records = 25_000
+    # CrateDB enforces statement_max_length=262144; keep well under that limit.
+    insert_records = 5_000
     cmd = f"time python insert_efficient.py cratedb multirow {insert_records}"
     run(cmd)
 
 
 def test_insert_efficient_batched():
-    insert_records = 50_000
+    insert_records = 5_000
     cmd = f"time python insert_efficient.py cratedb batched {insert_records}"
     run(cmd)
 
@@ -26,17 +27,20 @@ def test_insert_efficient_unknown(capfd):
     out, err = capfd.readouterr()
     assert "ValueError: Unknown variant: unknown" in err
 
-
+# TODO: Remove skip when psycopg/asyncpg dialect is released in sqlalchemy-cratedb
+@pytest.mark.skip(reason="psycopg/asyncpg dialect not yet in released sqlalchemy-cratedb")
 def test_sync_table():
     cmd = "time python sync_table.py urllib3 psycopg"
     run(cmd)
 
 
+@pytest.mark.skip(reason="psycopg/asyncpg dialect not yet in released sqlalchemy-cratedb")
 def test_async_table():
     cmd = "time python async_table.py psycopg asyncpg"
     run(cmd)
 
 
+@pytest.mark.skip(reason="psycopg/asyncpg dialect not yet in released sqlalchemy-cratedb")
 def test_async_streaming():
     cmd = "time python async_streaming.py psycopg asyncpg"
     run(cmd)