Changeset 197
- Timestamp:
- 10/19/07 10:47:08
- Files:
-
- trunk/geniusql/conns.py (modified) (6 diffs)
- trunk/geniusql/objects.py (modified) (1 diff)
- trunk/geniusql/providers/ado.py (modified) (1 diff)
- trunk/geniusql/providers/mysql.py (modified) (1 diff)
- trunk/geniusql/providers/postgres.py (modified) (2 diffs)
- trunk/geniusql/providers/psycopg.py (modified) (1 diff)
- trunk/geniusql/providers/sqlite.py (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
trunk/geniusql/conns.py
r170 r197 36 36 def __call__(self): 37 37 """Return a connection.""" 38 exc = None 38 39 for i in xrange(self.retry): 39 40 try: … … 42 43 self.refs[weakref.ref(w, self._release)] = w.conn 43 44 return w 44 except errors.OutOfConnectionsError :45 except errors.OutOfConnectionsError, exc: 45 46 time.sleep(i + 1) 46 47 conn = None 47 raise errors.OutOfConnectionsError() 48 if exc: 49 args = exc.args 50 else: 51 args = ["No connection found in %r iterations." % self.retry] 52 raise errors.OutOfConnectionsError(*args) 48 53 49 54 def _release(self, ref): … … 75 80 def __call__(self): 76 81 """Return a connection from the pool.""" 82 exc = None 77 83 for i in self.iterations: 78 84 try: … … 93 99 self.refs[weakref.ref(w, self._release)] = w.conn 94 100 return w 95 except errors.OutOfConnectionsError :101 except errors.OutOfConnectionsError, exc: 96 102 time.sleep(i) 97 103 conn = None 98 raise errors.OutOfConnectionsError() 104 105 if exc: 106 args = exc.args 107 else: 108 args = ["No connection found in %r iterations." % self.iterations] 109 raise errors.OutOfConnectionsError(*args) 99 110 100 111 def _release(self, ref): … … 155 166 return self.conns[threadid] 156 167 except KeyError: 168 exc = None 157 169 for i in xrange(self.retry): 158 170 try: … … 160 172 self.conns[threadid] = conn 161 173 return conn 162 except errors.OutOfConnectionsError :174 except errors.OutOfConnectionsError, exc: 163 175 conn = None 164 176 time.sleep(i + 1) 165 raise errors.OutOfConnectionsError() 177 if exc: 178 args = exc.args 179 else: 180 args = ["No connection found in %r iterations." % self.retry] 181 raise errors.OutOfConnectionsError(*args) 166 182 167 183 def shutdown(self): trunk/geniusql/objects.py
r195 r197 518 518 if t.name == tablename: 519 519 return t 520 raise errors.MappingError( tablename)520 raise errors.MappingError("Table % not found." % tablename) 521 521 522 522 def _get_columns(self, table, conn=None): trunk/geniusql/providers/ado.py
r154 r197 394 394 return self.tableclass(name, self.db.quote(name), 395 395 self, created=True) 396 raise errors.MappingError( tablename)396 raise errors.MappingError("Table %r not found." % tablename) 397 397 398 398 def _get_indices(self, table=None, conn=None): trunk/geniusql/providers/mysql.py
r188 r197 526 526 return self.tableclass(name, self.db.quote(name), 527 527 self, created=True) 528 raise errors.MappingError( tablename)528 raise errors.MappingError("Table %r not found." % tablename) 529 529 530 530 def _get_columns(self, table, conn=None): trunk/geniusql/providers/postgres.py
r180 r197 697 697 def _get_table(self, tablename, conn=None): 698 698 if (not self.discover_pg_tables) and tablename.startswith("pg_"): 699 raise errors.MappingError(tablename) 699 raise errors.MappingError( 700 "Table %r not found. Set schema.discover_pg_tables to True " 701 "if you want to discover Postgres system tables (pg_*)." % 702 tablename) 700 703 701 704 data, _ = self.db.fetch("SELECT oid FROM pg_class WHERE " … … 725 728 726 729 return t 727 raise errors.MappingError( tablename)730 raise errors.MappingError("Table %r not found." % tablename) 728 731 729 732 def _get_columns(self, table, conn=None): trunk/geniusql/providers/psycopg.py
r135 r197 41 41 except _psycopg.DatabaseError, x: 42 42 if x.args[0].startswith('could not connect'): 43 raise errors.OutOfConnectionsError( )43 raise errors.OutOfConnectionsError(*x.args) 44 44 raise 45 45 trunk/geniusql/providers/sqlite.py
r167 r197 682 682 return self.tableclass(name, self.db.quote(name), 683 683 self, created=True) 684 raise errors.MappingError( tablename)684 raise errors.MappingError("Table %r not found." % tablename) 685 685 686 686 def _get_columns(self, table, conn=None):
