7
7
from pprint import pprint
10
from threading import Thread, currentThread
16
from test_all import verbose, get_new_environment_path
19
# For Pythons w/distutils pybsddb
20
from bsddb3 import db, dbshelve
23
from bsddb import db, dbshelve
26
from bsddb3 import test_support
28
from test import test_support
10
from test_all import db, dbshelve, test_support, verbose, have_threads, \
11
get_new_environment_path
31
14
#----------------------------------------------------------------------
158
141
for key, value in musicdata.items():
159
142
if type(self.keytype) == type(''):
160
143
key = "%02d" % key
161
d.put(key, string.join(value, '|'), txn=txn)
144
d.put(key, '|'.join(value), txn=txn)
163
146
def createDB(self, txn=None):
244
227
rec = self.cur.first()
245
228
while rec is not None:
246
229
if type(self.keytype) == type(''):
247
self.assert_(string.atoi(rec[0])) # for primary db, key is a number
230
self.assert_(int(rec[0])) # for primary db, key is a number
249
232
self.assert_(rec[0] and type(rec[0]) == type(0))
250
233
count = count + 1
253
rec = self.cur.next()
236
rec = getattr(self.cur, "next")()
254
237
self.assertEqual(count, len(musicdata)) # all items accounted for
285
268
def getGenre(self, priKey, priData):
286
269
self.assertEqual(type(priData), type(""))
270
genre = priData.split('|')[2]
288
273
print 'getGenre key: %r data: %r' % (priKey, priData)
289
genre = string.split(priData, '|')[2]
290
275
if genre == 'Blues':
291
276
return db.DB_DONOTINDEX
410
395
for key, value in musicdata.items():
411
396
if type(self.keytype) == type(''):
412
397
key = "%02d" % key
413
d.put(key, string.join(value, '|'))
398
d.put(key, '|'.join(value))
415
400
def writer2(self, d):
416
401
for x in range(100, 600):
418
403
value = [key] * 4
419
d.put(key, string.join(value, '|'))
404
d.put(key, '|'.join(value))
422
407
class ThreadedAssociateHashTestCase(ShelveAssociateTestCase):
435
420
def test_suite():
436
421
suite = unittest.TestSuite()
438
if db.version() >= (3, 3, 11):
439
suite.addTest(unittest.makeSuite(AssociateErrorTestCase))
441
suite.addTest(unittest.makeSuite(AssociateHashTestCase))
442
suite.addTest(unittest.makeSuite(AssociateBTreeTestCase))
443
suite.addTest(unittest.makeSuite(AssociateRecnoTestCase))
445
if db.version() >= (4, 1):
446
suite.addTest(unittest.makeSuite(AssociateBTreeTxnTestCase))
448
suite.addTest(unittest.makeSuite(ShelveAssociateHashTestCase))
449
suite.addTest(unittest.makeSuite(ShelveAssociateBTreeTestCase))
450
suite.addTest(unittest.makeSuite(ShelveAssociateRecnoTestCase))
453
suite.addTest(unittest.makeSuite(ThreadedAssociateHashTestCase))
454
suite.addTest(unittest.makeSuite(ThreadedAssociateBTreeTestCase))
455
suite.addTest(unittest.makeSuite(ThreadedAssociateRecnoTestCase))
423
suite.addTest(unittest.makeSuite(AssociateErrorTestCase))
425
suite.addTest(unittest.makeSuite(AssociateHashTestCase))
426
suite.addTest(unittest.makeSuite(AssociateBTreeTestCase))
427
suite.addTest(unittest.makeSuite(AssociateRecnoTestCase))
429
if db.version() >= (4, 1):
430
suite.addTest(unittest.makeSuite(AssociateBTreeTxnTestCase))
432
suite.addTest(unittest.makeSuite(ShelveAssociateHashTestCase))
433
suite.addTest(unittest.makeSuite(ShelveAssociateBTreeTestCase))
434
suite.addTest(unittest.makeSuite(ShelveAssociateRecnoTestCase))
437
suite.addTest(unittest.makeSuite(ThreadedAssociateHashTestCase))
438
suite.addTest(unittest.makeSuite(ThreadedAssociateBTreeTestCase))
439
suite.addTest(unittest.makeSuite(ThreadedAssociateRecnoTestCase))