mirror of
https://github.com/launchbadge/sqlx
synced 2024-11-12 23:37:13 +00:00
9f7205e80f
* fix test suite * rustfmt * need Row * test: fix integration test scripts and update the upstream supported databases Signed-off-by: Atkins Chang <atkinschang@gmail.com> * ci(actions): update supported databases Signed-off-by: Atkins Chang <atkinschang@gmail.com> * ci(actions): use `pg_isready` instead of `sleep` to avoid error cause by database not ready Signed-off-by: Atkins Chang <atkinschang@gmail.com> * feat(core): add `trait PgConnectionInfo` for connection parameter status from server Signed-off-by: Atkins Chang <atkinschang@gmail.com> * test(postgres): fix integration test for postgres Signed-off-by: Atkins Chang <atkinschang@gmail.com> * test(mysql): fix integration tests Signed-off-by: Atkins Chang <atkinschang@gmail.com> * ci(actions): test database against the oldest and newest supported versions Signed-off-by: Atkins Chang <atkinschang@gmail.com> * docs(core): document `trait PgConnectionInfo` Signed-off-by: Atkins Chang <atkinschang@gmail.com> Co-authored-by: Montana Low <montanalow@gmail.com>
70 lines
1.8 KiB
Python
70 lines
1.8 KiB
Python
import subprocess
|
|
import sys
|
|
import time
|
|
from os import path
|
|
|
|
# base dir of sqlx workspace
|
|
dir_workspace = path.dirname(path.dirname(path.realpath(__file__)))
|
|
|
|
# dir of tests
|
|
dir_tests = path.join(dir_workspace, "tests")
|
|
|
|
|
|
# start database server and return a URL to use to connect
|
|
def start_database(driver, database, cwd):
|
|
if driver == "sqlite":
|
|
# short-circuit for sqlite
|
|
return f"sqlite://{path.join(cwd, database)}"
|
|
|
|
res = subprocess.run(
|
|
["docker-compose", "up", "-d", driver],
|
|
stdout=subprocess.PIPE,
|
|
stderr=subprocess.PIPE,
|
|
cwd=dir_tests,
|
|
)
|
|
|
|
if res.returncode != 0:
|
|
print(res.stderr, file=sys.stderr)
|
|
|
|
if b"done" in res.stderr:
|
|
time.sleep(30)
|
|
|
|
# determine appropriate port for driver
|
|
if driver.startswith("mysql") or driver.startswith("mariadb"):
|
|
port = 3306
|
|
|
|
elif driver.startswith("postgres"):
|
|
port = 5432
|
|
|
|
elif driver.startswith("mssql"):
|
|
port = 1433
|
|
|
|
else:
|
|
raise NotImplementedError
|
|
|
|
# find port
|
|
res = subprocess.run(
|
|
["docker", "inspect", f"-f='{{{{(index (index .NetworkSettings.Ports \"{port}/tcp\") 0).HostPort}}}}'",
|
|
f"sqlx_{driver}_1"],
|
|
stdout=subprocess.PIPE,
|
|
stderr=subprocess.PIPE,
|
|
cwd=dir_tests,
|
|
)
|
|
|
|
if res.returncode != 0:
|
|
print(res.stderr, file=sys.stderr)
|
|
|
|
port = int(res.stdout[1:-2].decode())
|
|
|
|
# construct appropriate database URL
|
|
if driver.startswith("mysql") or driver.startswith("mariadb"):
|
|
return f"mysql://root:password@127.0.0.1:{port}/{database}"
|
|
|
|
elif driver.startswith("postgres"):
|
|
return f"postgres://postgres:password@localhost:{port}/{database}"
|
|
|
|
elif driver.startswith("mssql"):
|
|
return f"mssql://sa:Password123!@127.0.0.1:{port}/{database}"
|
|
|
|
else:
|
|
raise NotImplementedError
|