summaryrefslogtreecommitdiff
path: root/sqlplain/tests
diff options
context:
space:
mode:
Diffstat (limited to 'sqlplain/tests')
-rw-r--r--sqlplain/tests/books-data.sql12
-rw-r--r--sqlplain/tests/books-schema.sql9
-rw-r--r--sqlplain/tests/sqlplain_ex.py24
-rw-r--r--sqlplain/tests/test_bcp.py8
-rw-r--r--sqlplain/tests/test_million.py60
-rw-r--r--sqlplain/tests/test_pager.py14
-rw-r--r--sqlplain/tests/test_qmark2pyformat.py53
-rw-r--r--sqlplain/tests/test_reset.py18
-rw-r--r--sqlplain/tests/test_table.py0
-rw-r--r--sqlplain/tests/test_truncate.py25
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)