test/test_db.py

   1 #
   2 # Copyright (c) 2001 Bizar Software Pty Ltd (http://www.bizarsoftware.com.au/)
   3 # This module is free software, and you may redistribute it and/or modify
   4 # under the same terms as Python, so long as this copyright message and
   5 # disclaimer are retained in their original form.
   6 #
   7 # IN NO EVENT SHALL BIZAR SOFTWARE PTY LTD BE LIABLE TO ANY PARTY FOR
   8 # DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES ARISING
   9 # OUT OF THE USE OF THIS CODE, EVEN IF THE AUTHOR HAS BEEN ADVISED OF THE
  10 # POSSIBILITY OF SUCH DAMAGE.
  11 #
  12 # BIZAR SOFTWARE PTY LTD SPECIFICALLY DISCLAIMS ANY WARRANTIES, INCLUDING,
  13 # BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
  14 # FOR A PARTICULAR PURPOSE.  THE CODE PROVIDED HEREUNDER IS ON AN "AS IS"
  15 # BASIS, AND THERE IS NO OBLIGATION WHATSOEVER TO PROVIDE MAINTENANCE,
  16 # SUPPORT, UPDATES, ENHANCEMENTS, OR MODIFICATIONS.
  17 #
  18 # $Id: test_db.py,v 1.15 2002-01-19 13:16:04 rochecompaan Exp $
  19
  20 import unittest, os, shutil
  21
  22 from roundup.hyperdb import String, Password, Link, Multilink, Date, \
  23     Interval, Class, DatabaseError
  24 from roundup.roundupdb import FileClass
  25 from roundup import date
  26
  27 def setupSchema(db, create):
  28     status = Class(db, "status", name=String())
  29     status.setkey("name")
  30     if create:
  31         status.create(name="unread")
  32         status.create(name="in-progress")
  33         status.create(name="testing")
  34         status.create(name="resolved")
  35     Class(db, "user", username=String(), password=Password())
  36     Class(db, "issue", title=String(), status=Link("status"),
  37         nosy=Multilink("user"), deadline=Date(), foo=Interval())
  38     FileClass(db, "file", name=String(), type=String())
  39     db.commit()
  40
  41 class MyTestCase(unittest.TestCase):
  42     def tearDown(self):
  43         if os.path.exists('_test_dir'):
  44             shutil.rmtree('_test_dir')
  45
  46 class config:
  47     DATABASE='_test_dir'
  48     MAILHOST = 'localhost'
  49     MAIL_DOMAIN = 'fill.me.in.'
  50     INSTANCE_NAME = 'Roundup issue tracker'
  51     ISSUE_TRACKER_EMAIL = 'issue_tracker@%s'%MAIL_DOMAIN
  52     ISSUE_TRACKER_WEB = 'http://some.useful.url/'
  53     ADMIN_EMAIL = 'roundup-admin@%s'%MAIL_DOMAIN
  54     FILTER_POSITION = 'bottom'      # one of 'top', 'bottom', 'top and bottom'
  55     ANONYMOUS_ACCESS = 'deny'       # either 'deny' or 'allow'
  56     ANONYMOUS_REGISTER = 'deny'     # either 'deny' or 'allow'
  57     MESSAGES_TO_AUTHOR = 'no'       # either 'yes' or 'no'
  58     EMAIL_SIGNATURE_POSITION = 'bottom'
  59
  60 class anydbmDBTestCase(MyTestCase):
  61     def setUp(self):
  62         from roundup.backends import anydbm
  63         # remove previous test, ignore errors
  64         if os.path.exists(config.DATABASE):
  65             shutil.rmtree(config.DATABASE)
  66         os.makedirs(config.DATABASE + '/files')
  67         self.db = anydbm.Database(config, 'test')
  68         setupSchema(self.db, 1)
  69
  70     def testChanges(self):
  71         self.db.issue.create(title="spam", status='1')
  72         self.db.issue.create(title="eggs", status='2')
  73         self.db.issue.create(title="ham", status='4')
  74         self.db.issue.create(title="arguments", status='2')
  75         self.db.issue.create(title="abuse", status='1')
  76         self.db.issue.addprop(fixer=Link("user"))
  77         props = self.db.issue.getprops()
  78         keys = props.keys()
  79         keys.sort()
  80         self.assertEqual(keys, ['deadline', 'fixer', 'foo', 'id', 'nosy',
  81             'status', 'title'])
  82         self.db.issue.set('5', status='2')
  83         self.db.issue.get('5', "status")
  84
  85         a = self.db.issue.get('5', "deadline")
  86         self.db.issue.set('5', deadline=date.Date())
  87         self.assertNotEqual(a, self.db.issue.get('5', "deadline"))
  88
  89         a = self.db.issue.get('5', "foo")
  90         self.db.issue.set('5', foo=date.Interval('-1d'))
  91         self.assertNotEqual(a, self.db.issue.get('5', "foo"))
  92
  93         self.db.status.get('2', "name")
  94         self.db.issue.get('5', "title")
  95         self.db.issue.find(status = self.db.status.lookup("in-progress"))
  96         self.db.commit()
  97         self.db.issue.history('5')
  98         self.db.status.history('1')
  99         self.db.status.history('2')
 100
 101     def testTransactions(self):
 102         num_issues = len(self.db.issue.list())
 103         files_dir = os.path.join('_test_dir', 'files')
 104         if os.path.exists(files_dir):
 105             num_files = len(os.listdir(files_dir))
 106         else:
 107             num_files = 0
 108         self.db.issue.create(title="don't commit me!", status='1')
 109         self.assertNotEqual(num_issues, len(self.db.issue.list()))
 110         self.db.rollback()
 111         self.assertEqual(num_issues, len(self.db.issue.list()))
 112         self.db.issue.create(title="please commit me!", status='1')
 113         self.assertNotEqual(num_issues, len(self.db.issue.list()))
 114         self.db.commit()
 115         self.assertNotEqual(num_issues, len(self.db.issue.list()))
 116         self.db.rollback()
 117         self.assertNotEqual(num_issues, len(self.db.issue.list()))
 118         self.db.file.create(name="test", type="text/plain", content="hi")
 119         self.db.rollback()
 120         self.assertEqual(num_files, len(os.listdir(files_dir)))
 121         self.db.file.create(name="test", type="text/plain", content="hi")
 122         self.db.commit()
 123         self.assertNotEqual(num_files, len(os.listdir(files_dir)))
 124         num_files2 = len(os.listdir(files_dir))
 125         self.db.file.create(name="test", type="text/plain", content="hi")
 126         self.db.rollback()
 127         self.assertNotEqual(num_files, len(os.listdir(files_dir)))
 128         self.assertEqual(num_files2, len(os.listdir(files_dir)))
 129
 130
 131     def testExceptions(self):
 132         # this tests the exceptions that should be raised
 133         ar = self.assertRaises
 134
 135         #
 136         # class create
 137         #
 138         # string property
 139         ar(TypeError, self.db.status.create, name=1)
 140         # invalid property name
 141         ar(KeyError, self.db.status.create, foo='foo')
 142         # key name clash
 143         ar(ValueError, self.db.status.create, name='unread')
 144         # invalid link index
 145         ar(IndexError, self.db.issue.create, title='foo', status='bar')
 146         # invalid link value
 147         ar(ValueError, self.db.issue.create, title='foo', status=1)
 148         # invalid multilink type
 149         ar(TypeError, self.db.issue.create, title='foo', status='1',
 150             nosy='hello')
 151         # invalid multilink index type
 152         ar(ValueError, self.db.issue.create, title='foo', status='1',
 153             nosy=[1])
 154         # invalid multilink index
 155         ar(IndexError, self.db.issue.create, title='foo', status='1',
 156             nosy=['10'])
 157
 158         #
 159         # class get
 160         #
 161         # invalid node id
 162         ar(IndexError, self.db.status.get, '10', 'name')
 163         # invalid property name
 164         ar(KeyError, self.db.status.get, '2', 'foo')
 165
 166         #
 167         # class set
 168         #
 169         # invalid node id
 170         ar(IndexError, self.db.issue.set, '1', name='foo')
 171         # invalid property name
 172         ar(KeyError, self.db.status.set, '1', foo='foo')
 173         # string property
 174         ar(TypeError, self.db.status.set, '1', name=1)
 175         # key name clash
 176         ar(ValueError, self.db.status.set, '2', name='unread')
 177         # set up a valid issue for me to work on
 178         self.db.issue.create(title="spam", status='1')
 179         # invalid link index
 180         ar(IndexError, self.db.issue.set, '1', title='foo', status='bar')
 181         # invalid link value
 182         ar(ValueError, self.db.issue.set, '1', title='foo', status=1)
 183         # invalid multilink type
 184         ar(TypeError, self.db.issue.set, '1', title='foo', status='1',
 185             nosy='hello')
 186         # invalid multilink index type
 187         ar(ValueError, self.db.issue.set, '1', title='foo', status='1',
 188             nosy=[1])
 189         # invalid multilink index
 190         ar(IndexError, self.db.issue.set, '1', title='foo', status='1',
 191             nosy=['10'])
 192
 193     def testJournals(self):
 194         self.db.issue.addprop(fixer=Link("user", do_journal='yes'))
 195         self.db.user.create(username="mary")
 196         self.db.user.create(username="pete")
 197         self.db.issue.create(title="spam", status='1')
 198         self.db.commit()
 199
 200         # journal entry for issue create
 201         journal = self.db.getjournal('issue', '1')
 202         self.assertEqual(1, len(journal))
 203         (nodeid, date_stamp, journaltag, action, params) = journal[0]
 204         self.assertEqual(nodeid, '1')
 205         self.assertEqual(journaltag, 'test')
 206         self.assertEqual(action, 'create')
 207         keys = params.keys()
 208         keys.sort()
 209         self.assertEqual(keys, ['deadline', 'fixer', 'foo', 'nosy',
 210             'status', 'title'])
 211         self.assertEqual(None,params['deadline'])
 212         self.assertEqual(None,params['fixer'])
 213         self.assertEqual(None,params['foo'])
 214         self.assertEqual([],params['nosy'])
 215         self.assertEqual('1',params['status'])
 216         self.assertEqual('spam',params['title'])
 217
 218         # journal entry for link
 219         journal = self.db.getjournal('user', '1')
 220         self.assertEqual(1, len(journal))
 221         self.db.issue.set('1', fixer='1')
 222         self.db.commit()
 223         journal = self.db.getjournal('user', '1')
 224         self.assertEqual(2, len(journal))
 225         (nodeid, date_stamp, journaltag, action, params) = journal[1]
 226         self.assertEqual('1', nodeid)
 227         self.assertEqual('test', journaltag)
 228         self.assertEqual('link', action)
 229         self.assertEqual(('issue', '1', 'fixer'), params)
 230
 231         # journal entry for unlink
 232         self.db.issue.set('1', fixer='2')
 233         self.db.commit()
 234         journal = self.db.getjournal('user', '1')
 235         self.assertEqual(3, len(journal))
 236         (nodeid, date_stamp, journaltag, action, params) = journal[2]
 237         self.assertEqual('1', nodeid)
 238         self.assertEqual('test', journaltag)
 239         self.assertEqual('unlink', action)
 240         self.assertEqual(('issue', '1', 'fixer'), params)
 241
 242     def testRetire(self):
 243         pass
 244
 245
 246 class anydbmReadOnlyDBTestCase(MyTestCase):
 247     def setUp(self):
 248         from roundup.backends import anydbm
 249         # remove previous test, ignore errors
 250         if os.path.exists(config.DATABASE):
 251             shutil.rmtree(config.DATABASE)
 252         os.makedirs(config.DATABASE + '/files')
 253         db = anydbm.Database(config, 'test')
 254         setupSchema(db, 1)
 255         self.db = anydbm.Database(config)
 256         setupSchema(self.db, 0)
 257
 258     def testExceptions(self):
 259         # this tests the exceptions that should be raised
 260         ar = self.assertRaises
 261
 262         # this tests the exceptions that should be raised
 263         ar(DatabaseError, self.db.status.create, name="foo")
 264         ar(DatabaseError, self.db.status.set, '1', name="foo")
 265         ar(DatabaseError, self.db.status.retire, '1')
 266
 267
 268 class bsddbDBTestCase(anydbmDBTestCase):
 269     def setUp(self):
 270         from roundup.backends import bsddb
 271         # remove previous test, ignore errors
 272         if os.path.exists(config.DATABASE):
 273             shutil.rmtree(config.DATABASE)
 274         os.makedirs(config.DATABASE + '/files')
 275         self.db = bsddb.Database(config, 'test')
 276         setupSchema(self.db, 1)
 277
 278 class bsddbReadOnlyDBTestCase(anydbmReadOnlyDBTestCase):
 279     def setUp(self):
 280         from roundup.backends import bsddb
 281         # remove previous test, ignore errors
 282         if os.path.exists(config.DATABASE):
 283             shutil.rmtree(config.DATABASE)
 284         os.makedirs(config.DATABASE + '/files')
 285         db = bsddb.Database(config, 'test')
 286         setupSchema(db, 1)
 287         self.db = bsddb.Database(config)
 288         setupSchema(self.db, 0)
 289
 290
 291 class bsddb3DBTestCase(anydbmDBTestCase):
 292     def setUp(self):
 293         from roundup.backends import bsddb3
 294         # remove previous test, ignore errors
 295         if os.path.exists(config.DATABASE):
 296             shutil.rmtree(config.DATABASE)
 297         os.makedirs(config.DATABASE + '/files')
 298         self.db = bsddb3.Database(config, 'test')
 299         setupSchema(self.db, 1)
 300
 301 class bsddb3ReadOnlyDBTestCase(anydbmReadOnlyDBTestCase):
 302     def setUp(self):
 303         from roundup.backends import bsddb3
 304         # remove previous test, ignore errors
 305         if os.path.exists(config.DATABASE):
 306             shutil.rmtree(config.DATABASE)
 307         os.makedirs(config.DATABASE + '/files')
 308         db = bsddb3.Database(config, 'test')
 309         setupSchema(db, 1)
 310         self.db = bsddb3.Database(config)
 311         setupSchema(self.db, 0)
 312
 313
 314 def suite():
 315     l = [unittest.makeSuite(anydbmDBTestCase, 'test'),
 316          unittest.makeSuite(anydbmReadOnlyDBTestCase, 'test')
 317     ]
 318
 319     try:
 320         import bsddb
 321         l.append(unittest.makeSuite(bsddbDBTestCase, 'test'))
 322         l.append(unittest.makeSuite(bsddbReadOnlyDBTestCase, 'test'))
 323     except:
 324         print 'bsddb module not found, skipping bsddb DBTestCase'
 325
 326 #    try:
 327 #        import bsddb3
 328 #        l.append(unittest.makeSuite(bsddb3DBTestCase, 'test'))
 329 #        l.append(unittest.makeSuite(bsddb3ReadOnlyDBTestCase, 'test'))
 330 #    except:
 331 #        print 'bsddb3 module not found, skipping bsddb3 DBTestCase'
 332
 333     return unittest.TestSuite(l)
 334
 335 #
 336 # $Log: not supported by cvs2svn $
 337 # Revision 1.14  2002/01/16 07:02:57  richard
 338 #  . lots of date/interval related changes:
 339 #    - more relaxed date format for input
 340 #
 341 # Revision 1.13  2002/01/14 02:20:15  richard
 342 #  . changed all config accesses so they access either the instance or the
 343 #    config attriubute on the db. This means that all config is obtained from
 344 #    instance_config instead of the mish-mash of classes. This will make
 345 #    switching to a ConfigParser setup easier too, I hope.
 346 #
 347 # At a minimum, this makes migration a _little_ easier (a lot easier in the
 348 # 0.5.0 switch, I hope!)
 349 #
 350 # Revision 1.12  2001/12/17 03:52:48  richard
 351 # Implemented file store rollback. As a bonus, the hyperdb is now capable of
 352 # storing more than one file per node - if a property name is supplied,
 353 # the file is called designator.property.
 354 # I decided not to migrate the existing files stored over to the new naming
 355 # scheme - the FileClass just doesn't specify the property name.
 356 #
 357 # Revision 1.11  2001/12/10 23:17:20  richard
 358 # Added transaction tests to test_db
 359 #
 360 # Revision 1.10  2001/12/03 21:33:39  richard
 361 # Fixes so the tests use commit and not close
 362 #
 363 # Revision 1.9  2001/12/02 05:06:16  richard
 364 # . We now use weakrefs in the Classes to keep the database reference, so
 365 #   the close() method on the database is no longer needed.
 366 #   I bumped the minimum python requirement up to 2.1 accordingly.
 367 # . #487480 ] roundup-server
 368 # . #487476 ] INSTALL.txt
 369 #
 370 # I also cleaned up the change message / post-edit stuff in the cgi client.
 371 # There's now a clearly marked "TODO: append the change note" where I believe
 372 # the change note should be added there. The "changes" list will obviously
 373 # have to be modified to be a dict of the changes, or somesuch.
 374 #
 375 # More testing needed.
 376 #
 377 # Revision 1.8  2001/10/09 07:25:59  richard
 378 # Added the Password property type. See "pydoc roundup.password" for
 379 # implementation details. Have updated some of the documentation too.
 380 #
 381 # Revision 1.7  2001/08/29 06:23:59  richard
 382 # Disabled the bsddb3 module entirely in the unit testing. See CHANGES for
 383 # details.
 384 #
 385 # Revision 1.6  2001/08/07 00:24:43  richard
 386 # stupid typo
 387 #
 388 # Revision 1.5  2001/08/07 00:15:51  richard
 389 # Added the copyright/license notice to (nearly) all files at request of
 390 # Bizar Software.
 391 #
 392 # Revision 1.4  2001/07/30 03:45:56  richard
 393 # Added more DB to test_db. Can skip tests where imports fail.
 394 #
 395 # Revision 1.3  2001/07/29 07:01:39  richard
 396 # Added vim command to all source so that we don't get no steenkin' tabs :)
 397 #
 398 # Revision 1.2  2001/07/29 04:09:20  richard
 399 # Added the fabricated property "id" to all hyperdb classes.
 400 #
 401 # Revision 1.1  2001/07/27 06:55:07  richard
 402 # moving tests -> test
 403 #
 404 # Revision 1.7  2001/07/27 06:26:43  richard
 405 # oops - wasn't deleting the test dir after the read-only tests
 406 #
 407 # Revision 1.6  2001/07/27 06:23:59  richard
 408 # consistency
 409 #
 410 # Revision 1.5  2001/07/27 06:23:09  richard
 411 # Added some new hyperdb tests to make sure we raise the right exceptions.
 412 #
 413 # Revision 1.4  2001/07/25 04:34:31  richard
 414 # Added id and log to tests files...
 415 #
 416 #
 417 # vim: set filetype=python ts=4 sw=4 et si