Add real table lifecycle integration test

Author: jarrenL

.gitignore

@@ -5,6 +5,7 @@ __pycache__/
 .mypy_cache/
 .ruff_cache/
 .venv/
+.idea/
 build/
 dist/
 release/

README.md

@@ -137,6 +137,7 @@ Windows 实机测试步骤、前置条件、测试场景和真实数据库地址
 集成测试覆盖：
 
 - SQLAlchemy Core DDL、DML、查询
+- 真实表生命周期：建表、表存在性检查、插入、查询、更新、删除和清理
 - 事务回滚
 - 批量插入
 - ORM CRUD

dist/gaussdb_sqlalchemy_driver-0.1.0-py3-none-any.whl

@@ -104,6 +104,7 @@ pytest -m integration tests/test_integration_env.py -q
 验证内容：
 
 - SQLAlchemy Core 建表、插入、查询。
+- 真实表生命周期：建表前存在性检查、建表后存在性检查、列反射、批量插入、条件查询、更新、删除、清理后存在性检查。
 - 事务回滚。
 - 批量插入。
 - ORM CRUD。
@@ -168,9 +169,9 @@ M 兼容: testm
 
 ```text
 本地单元测试: 43 passed, 19 skipped
-A 兼容 integration: 13 passed
-B 兼容 integration: 13 passed
-M 兼容 integration: 13 passed
+A 兼容 integration: 14 passed
+B 兼容 integration: 14 passed
+M 兼容 integration: 14 passed
 A/B/M 兼容场景测试: 18 passed
 ```
 

dist/gaussdb_sqlalchemy_driver-0.1.0.tar.gz

@@ -127,6 +127,71 @@ def test_bulk_insert_against_gaussdb_url_from_env():
         _drop_table(conn, table_name)
 
 
+@pytest.mark.integration
+def test_real_table_lifecycle_crud_against_gaussdb_url_from_env():
+    engine = _engine()
+    table_name = _table_name("gdbdrv_lifecycle_ut")
+    metadata = MetaData()
+    table = Table(
+        table_name,
+        metadata,
+        Column("id", Integer, primary_key=True),
+        Column("name", String(32), nullable=False),
+        Column("score", Integer, nullable=False),
+    )
+
+    try:
+        with engine.begin() as conn:
+            _drop_table(conn, table_name)
+            inspector = inspect(conn)
+            assert inspector.has_table(table_name) is False
+
+            table.create(conn)
+            inspector.clear_cache()
+            assert inspector.has_table(table_name) is True
+
+            columns = {column["name"]: column for column in inspector.get_columns(table_name)}
+            assert set(columns) == {"id", "name", "score"}
+            assert columns["id"]["nullable"] is False
+            assert columns["name"]["nullable"] is False
+            assert columns["score"]["nullable"] is False
+
+            conn.execute(
+                table.insert(),
+                [
+                    {"id": 1, "name": "alice", "score": 90},
+                    {"id": 2, "name": "bob", "score": 80},
+                    {"id": 3, "name": "carol", "score": 70},
+                ],
+            )
+
+            rows = conn.execute(
+                select(table.c.id, table.c.name, table.c.score)
+                .where(table.c.score >= 80)
+                .order_by(table.c.id)
+            ).all()
+            assert rows == [(1, "alice", 90), (2, "bob", 80)]
+
+            conn.execute(
+                table.update().where(table.c.id == 2).values(score=85)
+            )
+            assert conn.execute(
+                select(table.c.score).where(table.c.id == 2)
+            ).scalar_one() == 85
+
+            conn.execute(table.delete().where(table.c.score < 80))
+            remaining = conn.execute(
+                select(table.c.id, table.c.name, table.c.score).order_by(table.c.id)
+            ).all()
+            assert remaining == [(1, "alice", 90), (2, "bob", 85)]
+    finally:
+        with engine.begin() as conn:
+            _drop_table(conn, table_name)
+            inspector = inspect(conn)
+            inspector.clear_cache()
+            assert inspector.has_table(table_name) is False
+
+
 @pytest.mark.integration
 def test_orm_crud_against_gaussdb_url_from_env():
     engine = _engine()