from sqlalchemy import *
from sqlalchemy.testing import eq_
from sqlalchemy.testing import engines
from sqlalchemy.testing import fixtures
from sqlalchemy.testing.mock import Mock


def mock_dbapi():
    return Mock(paramstyle='qmark',
                connect=Mock(
                    return_value=Mock(
                        cursor=Mock(return_value=Mock(description=None,
                                                      rowcount=None)))))


class MxODBCTest(fixtures.TestBase):

    def test_native_odbc_execute(self):
        t1 = Table('t1', MetaData(), Column('c1', Integer))
        dbapi = mock_dbapi()

        engine = engines.testing_engine('mssql+mxodbc://localhost',
                                        options={'module': dbapi,
                                                 '_initialize': False})
        conn = engine.connect()

        # crud: uses execute
        conn.execute(t1.insert().values(c1='foo'))
        conn.execute(t1.delete().where(t1.c.c1 == 'foo'))
        conn.execute(t1.update().where(t1.c.c1 == 'foo').values(c1='bar'))

        # select: uses executedirect
        conn.execute(t1.select())

        # manual flagging
        conn.execution_options(native_odbc_execute=True).execute(t1.select())
        conn.execution_options(native_odbc_execute=False)\
            .execute(t1.insert().values(c1='foo'))

        eq_([c[2] for c in
            dbapi.connect.return_value.cursor.return_value.execute.mock_calls],
            [{'direct': True}, {'direct': True}, {'direct': True},
             {'direct': True}, {'direct': False}, {'direct': True}])