summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/dialects/mssql
diff options
context:
space:
mode:
authorDiana Clarke <diana.joan.clarke@gmail.com>2012-11-19 23:29:08 -0500
committerDiana Clarke <diana.joan.clarke@gmail.com>2012-11-19 23:29:08 -0500
commit014e9128546a0c32cdd90ad5ccdcc21269987ee0 (patch)
tree915a9c89a5d3cd5d914867b3ab628c5f6f33bd8b /lib/sqlalchemy/dialects/mssql
parente0dc5ed803de7a57de033c16f2fa0044b59ce374 (diff)
downloadsqlalchemy-014e9128546a0c32cdd90ad5ccdcc21269987ee0.tar.gz
juts a 'expected 2 blank lines' pep8 pass
Diffstat (limited to 'lib/sqlalchemy/dialects/mssql')
-rw-r--r--lib/sqlalchemy/dialects/mssql/adodbapi.py1
-rw-r--r--lib/sqlalchemy/dialects/mssql/base.py27
-rw-r--r--lib/sqlalchemy/dialects/mssql/information_schema.py1
-rw-r--r--lib/sqlalchemy/dialects/mssql/mxodbc.py4
-rw-r--r--lib/sqlalchemy/dialects/mssql/pymssql.py2
-rw-r--r--lib/sqlalchemy/dialects/mssql/pyodbc.py1
-rw-r--r--lib/sqlalchemy/dialects/mssql/zxjdbc.py1
7 files changed, 37 insertions, 0 deletions
diff --git a/lib/sqlalchemy/dialects/mssql/adodbapi.py b/lib/sqlalchemy/dialects/mssql/adodbapi.py
index 747ea17db..247c1ce8f 100644
--- a/lib/sqlalchemy/dialects/mssql/adodbapi.py
+++ b/lib/sqlalchemy/dialects/mssql/adodbapi.py
@@ -22,6 +22,7 @@ from sqlalchemy import types as sqltypes, util
from sqlalchemy.dialects.mssql.base import MSDateTime, MSDialect
import sys
+
class MSDateTime_adodbapi(MSDateTime):
def result_processor(self, dialect, coltype):
def process(value):
diff --git a/lib/sqlalchemy/dialects/mssql/base.py b/lib/sqlalchemy/dialects/mssql/base.py
index 09db05e1f..8292d08f1 100644
--- a/lib/sqlalchemy/dialects/mssql/base.py
+++ b/lib/sqlalchemy/dialects/mssql/base.py
@@ -216,6 +216,7 @@ RESERVED_WORDS = set(
'writetext',
])
+
class REAL(sqltypes.REAL):
__visit_name__ = 'REAL'
@@ -224,6 +225,7 @@ class REAL(sqltypes.REAL):
kw['precision'] = 24
super(REAL, self).__init__(**kw)
+
class TINYINT(sqltypes.Integer):
__visit_name__ = 'TINYINT'
@@ -256,6 +258,7 @@ class _MSDate(sqltypes.Date):
return value
return process
+
class TIME(sqltypes.TIME):
def __init__(self, precision=None, **kwargs):
self.precision = precision
@@ -287,6 +290,7 @@ class TIME(sqltypes.TIME):
return process
_MSTime = TIME
+
class _DateTimeBase(object):
def bind_processor(self, dialect):
def process(value):
@@ -296,12 +300,15 @@ class _DateTimeBase(object):
return value
return process
+
class _MSDateTime(_DateTimeBase, sqltypes.DateTime):
pass
+
class SMALLDATETIME(_DateTimeBase, sqltypes.DateTime):
__visit_name__ = 'SMALLDATETIME'
+
class DATETIME2(_DateTimeBase, sqltypes.DateTime):
__visit_name__ = 'DATETIME2'
@@ -317,12 +324,14 @@ class DATETIMEOFFSET(sqltypes.TypeEngine):
def __init__(self, precision=None, **kwargs):
self.precision = precision
+
class _StringType(object):
"""Base for MSSQL string types."""
def __init__(self, collation=None):
self.collation = collation
+
class TEXT(_StringType, sqltypes.TEXT):
"""MSSQL TEXT type, for variable-length text up to 2^31 characters."""
@@ -336,6 +345,7 @@ class TEXT(_StringType, sqltypes.TEXT):
_StringType.__init__(self, collation)
sqltypes.Text.__init__(self, length, **kw)
+
class NTEXT(_StringType, sqltypes.UnicodeText):
"""MSSQL NTEXT type, for variable-length unicode text up to 2^30
characters."""
@@ -381,6 +391,7 @@ class VARCHAR(_StringType, sqltypes.VARCHAR):
_StringType.__init__(self, collation)
sqltypes.VARCHAR.__init__(self, length, **kw)
+
class NVARCHAR(_StringType, sqltypes.NVARCHAR):
"""MSSQL NVARCHAR type.
@@ -398,6 +409,7 @@ class NVARCHAR(_StringType, sqltypes.NVARCHAR):
_StringType.__init__(self, collation)
sqltypes.NVARCHAR.__init__(self, length, **kw)
+
class CHAR(_StringType, sqltypes.CHAR):
"""MSSQL CHAR type, for fixed-length non-Unicode data with a maximum
of 8,000 characters."""
@@ -426,6 +438,7 @@ class CHAR(_StringType, sqltypes.CHAR):
_StringType.__init__(self, collation)
sqltypes.CHAR.__init__(self, length, **kw)
+
class NCHAR(_StringType, sqltypes.NCHAR):
"""MSSQL NCHAR type.
@@ -443,9 +456,11 @@ class NCHAR(_StringType, sqltypes.NCHAR):
_StringType.__init__(self, collation)
sqltypes.NCHAR.__init__(self, length, **kw)
+
class IMAGE(sqltypes.LargeBinary):
__visit_name__ = 'IMAGE'
+
class BIT(sqltypes.TypeEngine):
__visit_name__ = 'BIT'
@@ -453,12 +468,15 @@ class BIT(sqltypes.TypeEngine):
class MONEY(sqltypes.TypeEngine):
__visit_name__ = 'MONEY'
+
class SMALLMONEY(sqltypes.TypeEngine):
__visit_name__ = 'SMALLMONEY'
+
class UNIQUEIDENTIFIER(sqltypes.TypeEngine):
__visit_name__ = "UNIQUEIDENTIFIER"
+
class SQL_VARIANT(sqltypes.TypeEngine):
__visit_name__ = 'SQL_VARIANT'
@@ -641,6 +659,7 @@ class MSTypeCompiler(compiler.GenericTypeCompiler):
def visit_SQL_VARIANT(self, type_):
return 'SQL_VARIANT'
+
class MSExecutionContext(default.DefaultExecutionContext):
_enable_identity_insert = False
_select_lastrowid = False
@@ -718,6 +737,7 @@ class MSExecutionContext(default.DefaultExecutionContext):
else:
return engine.ResultProxy(self)
+
class MSSQLCompiler(compiler.SQLCompiler):
returning_precedes_values = True
@@ -947,6 +967,7 @@ class MSSQLCompiler(compiler.SQLCompiler):
fromhints=from_hints, **kw)
for t in [from_table] + extra_froms)
+
class MSSQLStrictCompiler(MSSQLCompiler):
"""A subclass of MSSQLCompiler which disables the usage of bind
parameters where not allowed natively by MS-SQL.
@@ -990,6 +1011,7 @@ class MSSQLStrictCompiler(MSSQLCompiler):
return super(MSSQLStrictCompiler, self).\
render_literal_value(value, type_)
+
class MSDDLCompiler(compiler.DDLCompiler):
def get_column_specification(self, column, **kwargs):
colspec = (self.preparer.format_column(column) + " "
@@ -1049,6 +1071,7 @@ class MSIdentifierPreparer(compiler.IdentifierPreparer):
result = '.'.join([self.quote(x, force) for x in schema.split('.')])
return result
+
def _db_plus_owner_listing(fn):
def wrap(dialect, connection, schema=None, **kw):
dbname, owner = _owner_plus_db(dialect, schema)
@@ -1056,6 +1079,7 @@ def _db_plus_owner_listing(fn):
dbname, owner, schema, **kw)
return update_wrapper(wrap, fn)
+
def _db_plus_owner(fn):
def wrap(dialect, connection, tablename, schema=None, **kw):
dbname, owner = _owner_plus_db(dialect, schema)
@@ -1063,6 +1087,7 @@ def _db_plus_owner(fn):
tablename, dbname, owner, schema, **kw)
return update_wrapper(wrap, fn)
+
def _switch_db(dbname, connection, fn, *arg, **kw):
if dbname:
current_db = connection.scalar("select db_name()")
@@ -1073,6 +1098,7 @@ def _switch_db(dbname, connection, fn, *arg, **kw):
if dbname:
connection.execute("use %s" % current_db)
+
def _owner_plus_db(dialect, schema):
if not schema:
return None, dialect.default_schema_name
@@ -1081,6 +1107,7 @@ def _owner_plus_db(dialect, schema):
else:
return None, schema
+
class MSDialect(default.DefaultDialect):
name = 'mssql'
supports_default_values = True
diff --git a/lib/sqlalchemy/dialects/mssql/information_schema.py b/lib/sqlalchemy/dialects/mssql/information_schema.py
index 30849e0ef..bd88a67d8 100644
--- a/lib/sqlalchemy/dialects/mssql/information_schema.py
+++ b/lib/sqlalchemy/dialects/mssql/information_schema.py
@@ -11,6 +11,7 @@ from ...types import String, Unicode, Integer, TypeDecorator
ischema = MetaData()
+
class CoerceUnicode(TypeDecorator):
impl = Unicode
diff --git a/lib/sqlalchemy/dialects/mssql/mxodbc.py b/lib/sqlalchemy/dialects/mssql/mxodbc.py
index 91922a442..ccafe0efe 100644
--- a/lib/sqlalchemy/dialects/mssql/mxodbc.py
+++ b/lib/sqlalchemy/dialects/mssql/mxodbc.py
@@ -54,6 +54,7 @@ class _MSNumeric_mxodbc(_MSNumeric_pyodbc):
"""Include pyodbc's numeric processor.
"""
+
class _MSDate_mxodbc(_MSDate):
def bind_processor(self, dialect):
def process(value):
@@ -63,6 +64,7 @@ class _MSDate_mxodbc(_MSDate):
return None
return process
+
class _MSTime_mxodbc(_MSTime):
def bind_processor(self, dialect):
def process(value):
@@ -72,6 +74,7 @@ class _MSTime_mxodbc(_MSTime):
return None
return process
+
class MSExecutionContext_mxodbc(MSExecutionContext_pyodbc):
"""
The pyodbc execution context is useful for enabling
@@ -82,6 +85,7 @@ class MSExecutionContext_mxodbc(MSExecutionContext_pyodbc):
# is really only being used in cases where OUTPUT
# won't work.
+
class MSDialect_mxodbc(MxODBCConnector, MSDialect):
# this is only needed if "native ODBC" mode is used,
diff --git a/lib/sqlalchemy/dialects/mssql/pymssql.py b/lib/sqlalchemy/dialects/mssql/pymssql.py
index 881893422..b51e88e36 100644
--- a/lib/sqlalchemy/dialects/mssql/pymssql.py
+++ b/lib/sqlalchemy/dialects/mssql/pymssql.py
@@ -28,6 +28,7 @@ from .base import MSDialect
from ... import types as sqltypes, util, processors
import re
+
class _MSNumeric_pymssql(sqltypes.Numeric):
def result_processor(self, dialect, type_):
if not self.asdecimal:
@@ -35,6 +36,7 @@ class _MSNumeric_pymssql(sqltypes.Numeric):
else:
return sqltypes.Numeric.result_processor(self, dialect, type_)
+
class MSDialect_pymssql(MSDialect):
supports_sane_rowcount = False
driver = 'pymssql'
diff --git a/lib/sqlalchemy/dialects/mssql/pyodbc.py b/lib/sqlalchemy/dialects/mssql/pyodbc.py
index 47a4851b0..8264347df 100644
--- a/lib/sqlalchemy/dialects/mssql/pyodbc.py
+++ b/lib/sqlalchemy/dialects/mssql/pyodbc.py
@@ -116,6 +116,7 @@ from ...connectors.pyodbc import PyODBCConnector
from ... import types as sqltypes, util
from ...util.compat import decimal
+
class _MSNumeric_pyodbc(sqltypes.Numeric):
"""Turns Decimals with adjusted() < 0 or > 7 into strings.
diff --git a/lib/sqlalchemy/dialects/mssql/zxjdbc.py b/lib/sqlalchemy/dialects/mssql/zxjdbc.py
index 1b36075b0..751af6efe 100644
--- a/lib/sqlalchemy/dialects/mssql/zxjdbc.py
+++ b/lib/sqlalchemy/dialects/mssql/zxjdbc.py
@@ -17,6 +17,7 @@ from ...connectors.zxJDBC import ZxJDBCConnector
from .base import MSDialect, MSExecutionContext
from ... import engine
+
class MSExecutionContext_zxjdbc(MSExecutionContext):
_embedded_scope_identity = False