diff options
Diffstat (limited to 'sqlplain/tests')
-rw-r--r-- | sqlplain/tests/books-data.sql | 12 | ||||
-rw-r--r-- | sqlplain/tests/books-schema.sql | 9 | ||||
-rw-r--r-- | sqlplain/tests/sqlplain_ex.py | 24 | ||||
-rw-r--r-- | sqlplain/tests/test_bcp.py | 8 | ||||
-rw-r--r-- | sqlplain/tests/test_million.py | 60 | ||||
-rw-r--r-- | sqlplain/tests/test_pager.py | 14 | ||||
-rw-r--r-- | sqlplain/tests/test_qmark2pyformat.py | 53 | ||||
-rw-r--r-- | sqlplain/tests/test_reset.py | 18 | ||||
-rw-r--r-- | sqlplain/tests/test_table.py | 0 | ||||
-rw-r--r-- | sqlplain/tests/test_truncate.py | 25 |
10 files changed, 0 insertions, 223 deletions
diff --git a/sqlplain/tests/books-data.sql b/sqlplain/tests/books-data.sql deleted file mode 100644 index 8429b9c..0000000 --- a/sqlplain/tests/books-data.sql +++ /dev/null @@ -1,12 +0,0 @@ --- populate score -INSERT INTO score VALUES ('+'); -INSERT INTO score VALUES ('O'); -INSERT INTO score VALUES ('O+'); -INSERT INTO score VALUES ('OO'); -INSERT INTO score VALUES ('OO+'); -INSERT INTO score VALUES ('OOO'); -INSERT INTO score VALUES ('OOO+'); -INSERT INTO score VALUES ('OOOO'); - ---populate books -INSERT INTO book VALUES ('Expert Python Programming', 'Ziadé', 'OOO+'); diff --git a/sqlplain/tests/books-schema.sql b/sqlplain/tests/books-schema.sql deleted file mode 100644 index 72d9089..0000000 --- a/sqlplain/tests/books-schema.sql +++ /dev/null @@ -1,9 +0,0 @@ -CREATE TABLE score( - score VARCHAR(4) PRIMARY KEY); - -CREATE TABLE book( - title VARCHAR(64), - author VARCHAR(64), - score VARCHAR(4) REFERENCES score (score), - PRIMARY KEY (author, title) -); diff --git a/sqlplain/tests/sqlplain_ex.py b/sqlplain/tests/sqlplain_ex.py deleted file mode 100644 index ea76b0e..0000000 --- a/sqlplain/tests/sqlplain_ex.py +++ /dev/null @@ -1,24 +0,0 @@ -from sqlplain import DB - -def test(autocommit): - db = DB('mssql://python:p1tone@192.168.0.129/srsdevbak', autocommit) - print db - print db.execute('select * from client') - print db.execute("update client set client='pippo' where 1=2") - - - db = DB('postgres://python:p1tone@localhost/rcare', autocommit) - print db - print db.execute('select * from customer') - print db.execute("update customer set client_id='pippo' where 1=2") - - db = DB('sqlite:///:memory:', autocommit) - print db - print db._raw_execute('create table prova (i integer)', (), None) - print db.execute("insert into prova values (1)") - print db.execute("select * from prova") - -if __name__ == '__main__': - test(autocommit=False) - test(autocommit=True) - diff --git a/sqlplain/tests/test_bcp.py b/sqlplain/tests/test_bcp.py deleted file mode 100644 index 811952b..0000000 --- a/sqlplain/tests/test_bcp.py +++ /dev/null @@ -1,8 +0,0 @@ -from sqlplain import connect -from sqlplain.mssql_util import * - -srs = connect('dbserver2') - -bcp_dump(srs.uri, 'client', '/tmp/client.bcpdump') - -bcp_restore(srs.uri, '/tmp/client.bcpdump', 'client') diff --git a/sqlplain/tests/test_million.py b/sqlplain/tests/test_million.py deleted file mode 100644 index bd47a7d..0000000 --- a/sqlplain/tests/test_million.py +++ /dev/null @@ -1,60 +0,0 @@ -""" -A test script to investigate the performance of load_file. -""" - -from __future__ import with_statement -import os, sys, csv, tempfile -from random import random -from datetime import date, timedelta -from sqlplain import do, util, table -from sqlplain.recipes import Clock - -create_price_table = do(''' -CREATE TABLE price( -code CHAR(4), -date DATE, -price FLOAT, -PRIMARY KEY (code, date) -) -''') - -clock = Clock(lambda et: sys.stdout.write('Elapsed time: %s\n' % et)) - -def makedatafile(ncodes, ndates): - "Create a big datafile with ncodes * ndates rows; return the file name" - tmp, fname = tempfile.mkstemp() - today = date.today() - for i in range(ncodes): - for j in range(ndates): - code = '%04d' % i - day = today - timedelta(j) - value = 1 + random() - os.write(tmp, '%s,%s,%s\n' % (code, day, value)) - os.close(tmp) - os.chmod(fname, 0755) - return fname - -def makedb(uri): - global fname - db = util.create_db(uri, force=True) - create_price_table(db) - fname = makedatafile(100, 100) - print 'Created datafile %s' % fname - return db - -def test(): - db = makedb('sqlite_test') - price = table.DTable.reflect(db, 'price') - with clock: - # 104 seconds for 100,000 rows on my MacBook - for r in csv.reader(file(fname)): - price.insert_row(r) - yield lambda x:x, 'insert_row' - price.truncate() - with clock: - # 2.4 seconds for 100,000 rows on my MacBook - price.load_file(fname, sep=',') - yield lambda x:x, 'load_file' - -def teardown(): - os.remove(fname) diff --git a/sqlplain/tests/test_pager.py b/sqlplain/tests/test_pager.py deleted file mode 100644 index 8ded9fb..0000000 --- a/sqlplain/tests/test_pager.py +++ /dev/null @@ -1,14 +0,0 @@ -from sqlplain import connect -from sqlplain.pager import SqlPaginator - -def setup(): - global pager - srs = connect('dbserver2') - pager = SqlPaginator(srs, ('select * from CSFBCreditDefaultSwaps', ()), - 'csfb_issuer_id') - -def test1(): - page = pager.fetchpage(64, 100) - for row in page: - print row.csfb_issuer_id - print 'pages, rows, size:', page.npages, page.nrows, len(page) diff --git a/sqlplain/tests/test_qmark2pyformat.py b/sqlplain/tests/test_qmark2pyformat.py deleted file mode 100644 index e535503..0000000 --- a/sqlplain/tests/test_qmark2pyformat.py +++ /dev/null @@ -1,53 +0,0 @@ -from __future__ import with_statement -from sqlplain.sql_support import qmark2pyformat, STRING_OR_COMMENT -from ms.time_utils import Clock - -TEMPL = ''' --- insert into covered -INSERT INTO rhp_covered_product - SELECT p.refdate, c.client_srs, c.client_id, p.pricer, ep.productcode, - ep.clientcode, rmtck.covered_date FROM rhp_exportedproduct AS ep - INNER JOIN customer AS c - ON lower(ep.client) = c.client_srs - INNER JOIN rhp_product AS p - ON ep.productcode = p.productcode - AND ep.refdate = p.refdate - AND p.refdate = ? - INNER JOIN ( - SELECT client_id, productcode, covered_date - FROM covered_by_nonrequested - - UNION - - SELECT client_id, productcode , covered_date FROM - covered_by_rhp_tickerlookup - - ) AS rmtck - ON c.client_id = rmtck.client_id - AND rmtck.productcode = p.productcode -''' - -#TEMPL = 'select * from client where client=?' - -def write(dt): - print "Spent %s ms" % dt - -with Clock(write): - for i in xrange(100000): - qmark2pyformat(TEMPL) - -def qmark2pyformat(templ): # version without cache - qmarks = 0 - out = [] - for i, chunk in enumerate(STRING_OR_COMMENT.split(templ)): - if i % 2 == 0: # real sql code - qmarks += chunk.count('?') - out.append(chunk.replace('?', '%s')) - else: # string or comment - out.append(chunk) - new_templ = ''.join(out) - return qmarks, new_templ - -with Clock(write): - for i in xrange(100000): - qmark2pyformat(TEMPL) diff --git a/sqlplain/tests/test_reset.py b/sqlplain/tests/test_reset.py deleted file mode 100644 index 1971e04..0000000 --- a/sqlplain/tests/test_reset.py +++ /dev/null @@ -1,18 +0,0 @@ -from sqlplain import connect, do - -def test_postgres(): - count_customers = do('select count(*) from customer', scalar=True) - conn = connect('postgres://python:p1tone@localhost/rcare') - print count_customers(conn) - conn._curs.close() # closed the cursor by hand to emulate an error - print count_customers(conn) - -def test_mssql(): - count_customers = do('select count(*) from client', scalar=True) - conn = connect('srs_dev') - print count_customers(conn) - conn._curs.close() # closed the cursor by hand to emulate an error - print count_customers(conn) - -if __name__ == '__main__': - test_mssql() diff --git a/sqlplain/tests/test_table.py b/sqlplain/tests/test_table.py deleted file mode 100644 index e69de29..0000000 --- a/sqlplain/tests/test_table.py +++ /dev/null diff --git a/sqlplain/tests/test_truncate.py b/sqlplain/tests/test_truncate.py deleted file mode 100644 index fbfb390..0000000 --- a/sqlplain/tests/test_truncate.py +++ /dev/null @@ -1,25 +0,0 @@ -from __future__ import with_statement -import os -from sqlplain import connect, util -from test_million import makedb, makedatafile, clock, create_price_table - -databases = 'postgres_test sqlite_test'.split() - - -def test_truncate(): - for uri in databases: - db = util.create_db(uri, force=True) - create_price_table(db) - fname = makedatafile(100, 100) - try: - util.load_file(db, fname, 'price') - with clock: - util.truncate_table(db, 'price') - yield lambda *a: None, uri, 'truncate' - - util.load_file(db, fname, 'price') - with clock: - db.execute('delete from price') - yield lambda *a: None, uri, 'delete' - finally: - os.remove(fname) |