summaryrefslogtreecommitdiff
path: root/test/dialect
diff options
context:
space:
mode:
Diffstat (limited to 'test/dialect')
-rw-r--r--test/dialect/mssql/test_query.py28
-rw-r--r--test/dialect/mysql/test_types.py7
-rw-r--r--test/dialect/oracle/test_compiler.py5
-rw-r--r--test/dialect/oracle/test_dialect.py17
-rw-r--r--test/dialect/oracle/test_types.py45
-rw-r--r--test/dialect/postgresql/test_dialect.py2
-rw-r--r--test/dialect/postgresql/test_types.py20
-rw-r--r--test/dialect/test_sqlite.py10
8 files changed, 56 insertions, 78 deletions
diff --git a/test/dialect/mssql/test_query.py b/test/dialect/mssql/test_query.py
index ef8c63d6b..46af4658d 100644
--- a/test/dialect/mssql/test_query.py
+++ b/test/dialect/mssql/test_query.py
@@ -211,34 +211,28 @@ class QueryUnicodeTest(fixtures.TestBase):
@testing.requires.mssql_freetds
@testing.requires.python2
+ @testing.provide_metadata
def test_convert_unicode(self):
- meta = MetaData(testing.db)
+ meta = self.metadata
t1 = Table(
"unitest_table",
meta,
Column("id", Integer, primary_key=True),
- Column("descr", mssql.MSText(convert_unicode=True)),
+ Column("descr", mssql.MSText()),
)
meta.create_all()
- con = testing.db.connect()
-
- # encode in UTF-8 (sting object) because this is the default
- # dialect encoding
-
- con.execute(
- ue(
- "insert into unitest_table values ('bien u\
- umang\xc3\xa9')"
- ).encode("UTF-8")
- )
- try:
- r = t1.select().execute().first()
+ with testing.db.connect() as con:
+ con.execute(
+ ue(
+ "insert into unitest_table values ('abc \xc3\xa9 def')"
+ ).encode("UTF-8")
+ )
+ r = con.execute(t1.select()).first()
assert isinstance(r[1], util.text_type), (
"%s is %s instead of unicode, working on %s"
% (r[1], type(r[1]), meta.bind)
)
- finally:
- meta.drop_all()
+ eq_(r[1], util.ue("abc \xc3\xa9 def"))
class QueryTest(testing.AssertsExecutionResults, fixtures.TestBase):
diff --git a/test/dialect/mysql/test_types.py b/test/dialect/mysql/test_types.py
index ed5bbcb2b..12f73fe24 100644
--- a/test/dialect/mysql/test_types.py
+++ b/test/dialect/mysql/test_types.py
@@ -1117,12 +1117,7 @@ class EnumSetTest(
"t",
self.metadata,
Column("id", Integer, primary_key=True),
- Column(
- "data",
- mysql.SET(
- u("réveillé"), u("drôle"), u("S’il"), convert_unicode=True
- ),
- ),
+ Column("data", mysql.SET(u("réveillé"), u("drôle"), u("S’il"))),
)
set_table.create()
diff --git a/test/dialect/oracle/test_compiler.py b/test/dialect/oracle/test_compiler.py
index a9c84ba49..596161ef2 100644
--- a/test/dialect/oracle/test_compiler.py
+++ b/test/dialect/oracle/test_compiler.py
@@ -211,7 +211,7 @@ class CompileTest(fixtures.TestBase, AssertsCompiledSQL):
eq_(len(c._result_columns), 2)
assert t.c.col1 in set(c._create_result_map()["col1"][1])
- s = select([t], for_update=True).limit(10).order_by(t.c.col2)
+ s = select([t]).with_for_update().limit(10).order_by(t.c.col2)
self.assert_compile(
s,
"SELECT col1, col2 FROM (SELECT "
@@ -222,7 +222,8 @@ class CompileTest(fixtures.TestBase, AssertsCompiledSQL):
)
s = (
- select([t], for_update=True)
+ select([t])
+ .with_for_update()
.limit(10)
.offset(20)
.order_by(t.c.col2)
diff --git a/test/dialect/oracle/test_dialect.py b/test/dialect/oracle/test_dialect.py
index 8d0e37188..1401d40d0 100644
--- a/test/dialect/oracle/test_dialect.py
+++ b/test/dialect/oracle/test_dialect.py
@@ -85,13 +85,12 @@ class OutParamTest(fixtures.TestBase, AssertsExecutionResults):
def test_out_params(self):
result = testing.db.execute(
text(
- "begin foo(:x_in, :x_out, :y_out, " ":z_out); end;",
- bindparams=[
- bindparam("x_in", Float),
- outparam("x_out", Integer),
- outparam("y_out", Float),
- outparam("z_out", String),
- ],
+ "begin foo(:x_in, :x_out, :y_out, " ":z_out); end;"
+ ).bindparams(
+ bindparam("x_in", Float),
+ outparam("x_out", Integer),
+ outparam("y_out", Float),
+ outparam("z_out", String),
),
x_in=5,
)
@@ -268,7 +267,7 @@ class ExecuteTest(fixtures.TestBase):
# here, we can't use ORDER BY.
eq_(
- t.select(for_update=True).limit(2).execute().fetchall(),
+ t.select().with_for_update().limit(2).execute().fetchall(),
[(1, 1), (2, 7)],
)
@@ -277,7 +276,7 @@ class ExecuteTest(fixtures.TestBase):
assert_raises_message(
exc.DatabaseError,
"ORA-02014",
- t.select(for_update=True).limit(2).offset(3).execute,
+ t.select().with_for_update().limit(2).offset(3).execute,
)
diff --git a/test/dialect/oracle/test_types.py b/test/dialect/oracle/test_types.py
index dbe91ec03..5af5459ff 100644
--- a/test/dialect/oracle/test_types.py
+++ b/test/dialect/oracle/test_types.py
@@ -556,15 +556,12 @@ class TypesTest(fixtures.TestBase):
)
row = testing.db.execute(
- text(
- stmt,
- typemap={
- "idata": Integer(),
- "ndata": Numeric(20, 2),
- "ndata2": Numeric(20, 2),
- "nidata": Numeric(5, 0),
- "fdata": Float(),
- },
+ text(stmt).columns(
+ idata=Integer(),
+ ndata=Numeric(20, 2),
+ ndata2=Numeric(20, 2),
+ nidata=Numeric(5, 0),
+ fdata=Float(),
)
).fetchall()[0]
eq_(
@@ -616,15 +613,12 @@ class TypesTest(fixtures.TestBase):
)
row = testing.db.execute(
- text(
- stmt,
- typemap={
- "anon_1_idata": Integer(),
- "anon_1_ndata": Numeric(20, 2),
- "anon_1_ndata2": Numeric(20, 2),
- "anon_1_nidata": Numeric(5, 0),
- "anon_1_fdata": Float(),
- },
+ text(stmt).columns(
+ anon_1_idata=Integer(),
+ anon_1_ndata=Numeric(20, 2),
+ anon_1_ndata2=Numeric(20, 2),
+ anon_1_nidata=Numeric(5, 0),
+ anon_1_fdata=Float(),
)
).fetchall()[0]
eq_(
@@ -643,15 +637,12 @@ class TypesTest(fixtures.TestBase):
)
row = testing.db.execute(
- text(
- stmt,
- typemap={
- "anon_1_idata": Integer(),
- "anon_1_ndata": Numeric(20, 2, asdecimal=False),
- "anon_1_ndata2": Numeric(20, 2, asdecimal=False),
- "anon_1_nidata": Numeric(5, 0, asdecimal=False),
- "anon_1_fdata": Float(asdecimal=True),
- },
+ text(stmt).columns(
+ anon_1_idata=Integer(),
+ anon_1_ndata=Numeric(20, 2, asdecimal=False),
+ anon_1_ndata2=Numeric(20, 2, asdecimal=False),
+ anon_1_nidata=Numeric(5, 0, asdecimal=False),
+ anon_1_fdata=Float(asdecimal=True),
)
).fetchall()[0]
eq_(
diff --git a/test/dialect/postgresql/test_dialect.py b/test/dialect/postgresql/test_dialect.py
index d4e1cddc4..cadcbdc1c 100644
--- a/test/dialect/postgresql/test_dialect.py
+++ b/test/dialect/postgresql/test_dialect.py
@@ -407,7 +407,7 @@ class MiscBackendTest(
@testing.fails_on("+zxjdbc", "psycopg2/pg8000 specific assertion")
@testing.requires.psycopg2_or_pg8000_compatibility
def test_numeric_raise(self):
- stmt = text("select cast('hi' as char) as hi", typemap={"hi": Numeric})
+ stmt = text("select cast('hi' as char) as hi").columns(hi=Numeric)
assert_raises(exc.InvalidRequestError, testing.db.execute, stmt)
@testing.only_if(
diff --git a/test/dialect/postgresql/test_types.py b/test/dialect/postgresql/test_types.py
index f20f92251..e55754f1b 100644
--- a/test/dialect/postgresql/test_types.py
+++ b/test/dialect/postgresql/test_types.py
@@ -165,8 +165,9 @@ class EnumTest(fixtures.TestBase, AssertsExecutionResults):
'zxjdbc fails on ENUM: column "XXX" is of type '
"XXX but expression is of type character varying",
)
+ @testing.provide_metadata
def test_create_table(self):
- metadata = MetaData(testing.db)
+ metadata = self.metadata
t1 = Table(
"table",
metadata,
@@ -175,19 +176,16 @@ class EnumTest(fixtures.TestBase, AssertsExecutionResults):
"value", Enum("one", "two", "three", name="onetwothreetype")
),
)
- t1.create()
- t1.create(checkfirst=True) # check the create
- try:
- t1.insert().execute(value="two")
- t1.insert().execute(value="three")
- t1.insert().execute(value="three")
+ with testing.db.connect() as conn:
+ t1.create(conn)
+ t1.create(conn, checkfirst=True) # check the create
+ conn.execute(t1.insert(), value="two")
+ conn.execute(t1.insert(), value="three")
+ conn.execute(t1.insert(), value="three")
eq_(
- t1.select().order_by(t1.c.id).execute().fetchall(),
+ conn.execute(t1.select().order_by(t1.c.id)).fetchall(),
[(1, "two"), (2, "three"), (3, "three")],
)
- finally:
- metadata.drop_all()
- metadata.drop_all()
def test_name_required(self):
metadata = MetaData(testing.db)
diff --git a/test/dialect/test_sqlite.py b/test/dialect/test_sqlite.py
index c480653b3..adfca5b53 100644
--- a/test/dialect/test_sqlite.py
+++ b/test/dialect/test_sqlite.py
@@ -116,7 +116,7 @@ class TestTypes(fixtures.TestBase, AssertsExecutionResults):
ValueError,
"Couldn't parse %s string." % disp,
lambda: testing.db.execute(
- text("select 'ASDF' as value", typemap={"value": typ})
+ text("select 'ASDF' as value").columns(value=typ)
).scalar(),
)
@@ -254,12 +254,12 @@ class TestTypes(fixtures.TestBase, AssertsExecutionResults):
dialect = sqlite.dialect()
for t in (
- String(convert_unicode=True),
- sqltypes.CHAR(convert_unicode=True),
+ String(),
+ sqltypes.CHAR(),
sqltypes.Unicode(),
sqltypes.UnicodeText(),
- String(convert_unicode=True),
- sqltypes.CHAR(convert_unicode=True),
+ String(),
+ sqltypes.CHAR(),
sqltypes.Unicode(),
sqltypes.UnicodeText(),
):