test: add system test + fix conformance 1.3 test

Author: olavloite

google/cloud/sqlalchemy_spanner/sqlalchemy_spanner.py

@@ -410,7 +410,9 @@ def get_column_specification(self, column, **kwargs):
             colspec += " NOT NULL"
 
         has_identity = (
-            column.identity is not None and self.dialect.supports_identity_columns
+            hasattr(column, "identity")
+            and column.identity is not None
+            and self.dialect.supports_identity_columns
         )
         default = self.get_column_default_string(column)
 

test/system/test_basics.py

@@ -23,11 +23,11 @@
     Index,
     MetaData,
     Boolean,
-    BIGINT,
+    BIGINT, select,
 )
 from sqlalchemy.orm import Session, DeclarativeBase, Mapped, mapped_column
 from sqlalchemy.types import REAL
-from sqlalchemy.testing import eq_
+from sqlalchemy.testing import eq_, is_true
 from sqlalchemy.testing.plugin.plugin_base import fixtures
 
 
@@ -50,6 +50,12 @@ def define_tables(cls, metadata):
             numbers.c.prime.desc(),
             spanner_storing=[numbers.c.alternative_name],
         )
+        Table(
+            "users",
+            metadata,
+            Column("ID", Integer, primary_key=True),
+            Column("name", String(20)),
+        )
 
     def test_hello_world(self, connection):
         greeting = connection.execute(text("select 'Hello World'"))
@@ -69,7 +75,7 @@ def test_reflect(self, connection):
         engine = connection.engine
         meta: MetaData = MetaData()
         meta.reflect(bind=engine)
-        eq_(1, len(meta.tables))
+        eq_(2, len(meta.tables))
         table = meta.tables["numbers"]
         eq_(5, len(table.columns))
         eq_("number", table.columns[0].name)
@@ -127,10 +133,25 @@ class Number(Base):
             prime: Mapped[bool] = mapped_column(Boolean)
             ln: Mapped[float] = mapped_column(REAL)
 
+        class User(Base):
+            __tablename__ = "users"
+            ID: Mapped[int] = mapped_column(primary_key=True)
+            name: Mapped[str] = mapped_column(String(20))
+
         engine = connection.engine
         with Session(engine) as session:
             number = Number(
                 number=1, name="One", alternative_name="Uno", prime=False, ln=0.0
             )
             session.add(number)
             session.commit()
+
+        with Session(engine) as session:
+            user = User(name="Test")
+            session.add(user)
+            session.commit()
+
+            statement = select(User).filter_by(name="Test")
+            users = session.scalars(statement).all()
+            eq_(1, len(users))
+            is_true(users[0].ID > 0)