Initial import

src/test/data/create.sql

@@ -0,0 +1,7 @@
+create table konto (
+"KONTO_ID" TIMESTAMP default CURRENT_TIMESTAMP not null,
+"KONTO_NR" INTEGER not null,
+"SALDO" DECIMAL default 0.0 not null,
+primary key ("KONTO_ID")
+);
+

src/test/data/insert.sql

@@ -0,0 +1,2 @@
+insert into Konto values ('2009-09-10 14:15:22.123456', 18, 12.4);
+insert into Konto values ('2009-09-11 14:15:22.123456', 19, 12.9);

src/test/integration_test.py

@@ -0,0 +1,145 @@
+#-*- coding: utf-8 -*-
+
+# Copyright 2010 Bastian Bowe
+#
+# This file is part of JayDeBeApi.
+# JayDeBeApi is free software: you can redistribute it and/or modify
+# it under the terms of the GNU Lesser General Public License as
+# published by the Free Software Foundation, either version 3 of the
+# License, or (at your option) any later version.
+# 
+# JayDeBeApi is distributed in the hope that it will be useful, but
+# WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+# Lesser General Public License for more details.
+# 
+# You should have received a copy of the GNU Lesser General Public
+# License along with JayDeBeApi.  If not, see
+# <http://www.gnu.org/licenses/>.
+
+import os
+from unittest import TestCase
+import jaydebeapi
+import sys
+
+this_dir = os.path.dirname(os.path.abspath(__file__))
+jar_dir = os.path.abspath(os.path.join(this_dir, '..', '..',
+                                       'build', 'lib'))
+create_sql = os.path.join(this_dir, 'data', 'create.sql')
+insert_sql = os.path.join(this_dir, 'data', 'insert.sql')
+
+def is_jython():
+     return sys.platform.lower().startswith('java')
+
+class IntegrationTest(TestCase):
+
+    def sql_file(self, filename):
+        f = open(filename, 'r')
+        try:
+            lines = f.readlines()
+        finally:
+            f.close()
+        stmt = []
+        stmts = []
+        for i in lines:
+            stmt.append(i)
+            if ";" in i:
+                stmts.append(" ".join(stmt))
+                stmt = []
+        cursor = self.conn.cursor()
+        for i in stmts:
+            cursor.execute(i)
+
+    def setup_jpype(self, jars):
+        import jpype
+        if not jpype.isJVMStarted():
+            jvm_path = jpype.getDefaultJVMPath()
+            #jvm_path = ('/usr/lib/jvm/java-6-openjdk'
+            #            '/jre/lib/i386/client/libjvm.so')
+            args='-Djava.class.path=%s' % jars
+            jpype.startJVM(jvm_path, args)
+        if not jpype.isThreadAttachedToJVM():
+            jpype.attachThreadToJVM()
+
+    def setUp(self):
+        # TODO support more than one jar
+        #jars='/usr/share/java/hsqldb.jar'
+        jars=os.path.join(jar_dir, 'hsqldb.jar')
+        #jars=jars_path(r'C:\Programme\DbVisualizer-4.3.5\jdbc')
+        if is_jython():
+            sys.path.append(jars)
+        else:
+            self.setup_jpype(jars)
+        self.conn = jaydebeapi.connect('org.hsqldb.jdbcDriver',
+                                    'jdbc:hsqldb:mem', 'SA', '')
+        #conn = jaydebeapi.connect('com.ibm.db2.jcc.DB2Driver',
+        #    'jdbc:db2://4.100.73.81:50000/db2t',
+        #    getpass.getuser(), getpass.getpass())
+        self.sql_file(create_sql)
+        self.sql_file(insert_sql)
+
+    def tearDown(self):
+        cursor = self.conn.cursor()
+        cursor.execute("drop table konto");
+        self.conn.close()
+
+    def test_execute_and_fetch_no_data(self):
+        cursor = self.conn.cursor()
+        stmt = "select * from konto where konto_id is null"
+        cursor.execute(stmt)
+        assert [] == cursor.fetchall()
+
+    def test_execute_and_fetch(self):
+        cursor = self.conn.cursor()
+        cursor.execute("select * from konto")
+        result = cursor.fetchall()
+        assert [(u'2009-09-10 14:15:22.123456', 18, 12.4),
+         (u'2009-09-11 14:15:22.123456', 19, 12.9)] == result
+
+    def test_execute_and_fetch_parameter(self):
+        cursor = self.conn.cursor()
+        cursor.execute("select * from konto where konto_nr = ?", 18)
+        result = cursor.fetchall()
+        assert [(u'2009-09-10 14:15:22.123456', 18, 12.4)] == result
+
+    def test_execute_and_fetchone(self):
+        cursor = self.conn.cursor()
+        cursor.execute("select * from konto order by konto_nr")
+        result = cursor.fetchone()
+        assert (u'2009-09-10 14:15:22.123456', 18, 12.4) == result
+
+    def test_execute_reset_description_without_execute_result(self):
+        """Excpect the descriptions property being reset when no query
+        has been made via execute method.
+        """
+        cursor = self.conn.cursor()
+        cursor.execute("select * from konto")
+        assert None != cursor.description
+        cursor.fetchone()
+        cursor.execute("delete from konto")
+        assert None == cursor.description
+
+    def test_execute_and_fetchone_after_end(self):
+        cursor = self.conn.cursor()
+        cursor.execute("select * from konto where konto_nr = ?", 18)
+        cursor.fetchone()
+        result = cursor.fetchone()
+        assert None is result
+
+    def test_execute_and_fetchmany(self):
+        cursor = self.conn.cursor()
+        cursor.execute("select * from konto order by konto_nr")
+        result = cursor.fetchmany()
+        assert [(u'2009-09-10 14:15:22.123456', 18, 12.4)] == result
+
+    def test_executemany(self):
+        cursor = self.conn.cursor()
+        stmt = "insert into Konto (KONTO_ID, KONTO_NR, SALDO) values (?, ?, ?)"
+        parms = (
+            ( '2009-09-11 14:15:22.123450', 20, 13.1 ),
+            ( '2009-09-11 14:15:22.123451', 21, 13.2 ),
+            ( '2009-09-11 14:15:22.123452', 22, 13.3 ),
+            )
+        cursor.executemany(stmt, parms)
+        assert cursor.rowcount == 3
+