Skip to content
Projeler
Gruplar
Parçacıklar
Yardım
Yükleniyor...
Oturum aç / Kaydol
Gezinmeyi değiştir
C
cpython
Proje
Proje
Ayrıntılar
Etkinlik
Cycle Analytics
Depo (repository)
Depo (repository)
Dosyalar
Kayıtlar (commit)
Dallar (branch)
Etiketler
Katkıda bulunanlar
Grafik
Karşılaştır
Grafikler
Konular (issue)
0
Konular (issue)
0
Liste
Pano
Etiketler
Kilometre Taşları
Birleştirme (merge) Talepleri
0
Birleştirme (merge) Talepleri
0
CI / CD
CI / CD
İş akışları (pipeline)
İşler
Zamanlamalar
Grafikler
Paketler
Paketler
Wiki
Wiki
Parçacıklar
Parçacıklar
Üyeler
Üyeler
Collapse sidebar
Close sidebar
Etkinlik
Grafik
Grafikler
Yeni bir konu (issue) oluştur
İşler
Kayıtlar (commit)
Konu (issue) Panoları
Kenar çubuğunu aç
Batuhan Osman TASKAYA
cpython
Commits
a65e94c1
Kaydet (Commit)
a65e94c1
authored
Agu 22, 2007
tarafından
Collin Winter
Dosyalara gözat
Seçenekler
Dosyalara Gözat
İndir
Eposta Yamaları
Sade Fark
Convert raise statements in bsddb.
üst
865ea892
Hide whitespace changes
Inline
Side-by-side
Showing
9 changed files
with
33 additions
and
33 deletions
+33
-33
__init__.py
Lib/bsddb/__init__.py
+3
-3
db.py
Lib/bsddb/db.py
+1
-1
dbrecio.py
Lib/bsddb/dbrecio.py
+7
-7
dbshelve.py
Lib/bsddb/dbshelve.py
+2
-2
dbtables.py
Lib/bsddb/dbtables.py
+14
-14
test_basics.py
Lib/bsddb/test/test_basics.py
+2
-2
test_compare.py
Lib/bsddb/test/test_compare.py
+1
-1
test_dbtables.py
Lib/bsddb/test/test_dbtables.py
+1
-1
test_pickle.py
Lib/bsddb/test/test_pickle.py
+2
-2
No files found.
Lib/bsddb/__init__.py
Dosyayı görüntüle @
a65e94c1
...
...
@@ -199,7 +199,7 @@ class _DBWithCursor(_iter_mixin):
def
_checkOpen
(
self
):
if
self
.
db
is
None
:
raise
error
,
"BSDDB object has already been closed"
raise
error
(
"BSDDB object has already been closed"
)
def
isOpen
(
self
):
return
self
.
db
is
not
None
...
...
@@ -483,7 +483,7 @@ def _openDBEnv(cachesize):
if
cachesize
>=
20480
:
e
.
set_cachesize
(
0
,
cachesize
)
else
:
raise
error
,
"cachesize must be >= 20480"
raise
error
(
"cachesize must be >= 20480"
)
e
.
set_lk_detect
(
db
.
DB_LOCK_DEFAULT
)
e
.
open
(
'.'
,
db
.
DB_PRIVATE
|
db
.
DB_CREATE
|
db
.
DB_THREAD
|
db
.
DB_INIT_LOCK
|
db
.
DB_INIT_MPOOL
)
return
e
...
...
@@ -505,7 +505,7 @@ def _checkflag(flag, file):
if
file
is
not
None
and
os
.
path
.
isfile
(
file
):
os
.
unlink
(
file
)
else
:
raise
error
,
"flags should be one of 'r', 'w', 'c' or 'n', not "
+
repr
(
flag
)
raise
error
(
"flags should be one of 'r', 'w', 'c' or 'n', not "
+
repr
(
flag
)
)
return
flags
|
db
.
DB_THREAD
#----------------------------------------------------------------------
...
...
Lib/bsddb/db.py
Dosyayı görüntüle @
a65e94c1
...
...
@@ -48,4 +48,4 @@ else:
from
_bsddb
import
__version__
if
version
()
<
(
3
,
2
,
0
):
raise
ImportError
,
"correct BerkeleyDB symbols not found. Perhaps python was statically linked with an older version?"
raise
ImportError
(
"correct BerkeleyDB symbols not found. Perhaps python was statically linked with an older version?"
)
Lib/bsddb/dbrecio.py
Dosyayı görüntüle @
a65e94c1
...
...
@@ -46,12 +46,12 @@ class DBRecIO:
def
isatty
(
self
):
if
self
.
closed
:
raise
ValueError
,
"I/O operation on closed file"
raise
ValueError
(
"I/O operation on closed file"
)
return
0
def
seek
(
self
,
pos
,
mode
=
0
):
if
self
.
closed
:
raise
ValueError
,
"I/O operation on closed file"
raise
ValueError
(
"I/O operation on closed file"
)
if
mode
==
1
:
pos
=
pos
+
self
.
pos
elif
mode
==
2
:
...
...
@@ -60,12 +60,12 @@ class DBRecIO:
def
tell
(
self
):
if
self
.
closed
:
raise
ValueError
,
"I/O operation on closed file"
raise
ValueError
(
"I/O operation on closed file"
)
return
self
.
pos
def
read
(
self
,
n
=
-
1
):
if
self
.
closed
:
raise
ValueError
,
"I/O operation on closed file"
raise
ValueError
(
"I/O operation on closed file"
)
if
n
<
0
:
newpos
=
self
.
len
else
:
...
...
@@ -111,7 +111,7 @@ class DBRecIO:
def
truncate
(
self
,
size
=
None
):
if
self
.
closed
:
raise
ValueError
,
"I/O operation on closed file"
raise
ValueError
(
"I/O operation on closed file"
)
if
size
is
None
:
size
=
self
.
pos
elif
size
<
0
:
...
...
@@ -123,7 +123,7 @@ class DBRecIO:
def
write
(
self
,
s
):
if
self
.
closed
:
raise
ValueError
,
"I/O operation on closed file"
raise
ValueError
(
"I/O operation on closed file"
)
if
not
s
:
return
if
self
.
pos
>
self
.
len
:
self
.
buflist
.
append
(
'
\0
'
*
(
self
.
pos
-
self
.
len
))
...
...
@@ -137,7 +137,7 @@ class DBRecIO:
def
flush
(
self
):
if
self
.
closed
:
raise
ValueError
,
"I/O operation on closed file"
raise
ValueError
(
"I/O operation on closed file"
)
"""
...
...
Lib/bsddb/dbshelve.py
Dosyayı görüntüle @
a65e94c1
...
...
@@ -69,7 +69,7 @@ def open(filename, flags=db.DB_CREATE, mode=0o660, filetype=db.DB_HASH,
elif
sflag
==
'n'
:
flags
=
db
.
DB_TRUNCATE
|
db
.
DB_CREATE
else
:
raise
db
.
DBError
,
"flags should be one of 'r', 'w', 'c' or 'n' or use the bsddb.db.DB_* flags"
raise
db
.
DBError
(
"flags should be one of 'r', 'w', 'c' or 'n' or use the bsddb.db.DB_* flags"
)
d
=
DBShelf
(
dbenv
)
d
.
open
(
filename
,
dbname
,
filetype
,
flags
,
mode
)
...
...
@@ -155,7 +155,7 @@ class DBShelf(DictMixin):
if
self
.
get_type
()
!=
db
.
DB_RECNO
:
self
.
append
=
self
.
__append
return
self
.
append
(
value
,
txn
=
txn
)
raise
db
.
DBError
,
"append() only supported when dbshelve opened with filetype=dbshelve.db.DB_RECNO"
raise
db
.
DBError
(
"append() only supported when dbshelve opened with filetype=dbshelve.db.DB_RECNO"
)
def
associate
(
self
,
secondaryDB
,
callback
,
flags
=
0
):
...
...
Lib/bsddb/dbtables.py
Dosyayı görüntüle @
a65e94c1
...
...
@@ -244,7 +244,7 @@ class bsdTableDB :
columnlist_key
=
_columns_key
(
table
)
if
self
.
db
.
has_key
(
columnlist_key
):
raise
TableAlreadyExists
,
"table already exists"
raise
TableAlreadyExists
(
"table already exists"
)
txn
=
self
.
env
.
txn_begin
()
# store the table's column info
...
...
@@ -261,7 +261,7 @@ class bsdTableDB :
txn
.
commit
()
txn
=
None
except
DBError
as
dberror
:
raise
TableDBError
,
dberror
.
args
[
1
]
raise
TableDBError
(
dberror
.
args
[
1
])
finally
:
if
txn
:
txn
.
abort
()
...
...
@@ -273,7 +273,7 @@ class bsdTableDB :
"""
assert
isinstance
(
table
,
str
)
if
contains_metastrings
(
table
):
raise
ValueError
,
"bad table name: contains reserved metastrings"
raise
ValueError
(
"bad table name: contains reserved metastrings"
)
columnlist_key
=
_columns_key
(
table
)
if
not
self
.
db
.
has_key
(
columnlist_key
):
...
...
@@ -340,7 +340,7 @@ class bsdTableDB :
self
.
__load_column_info
(
table
)
except
DBError
as
dberror
:
raise
TableDBError
,
dberror
.
args
[
1
]
raise
TableDBError
(
dberror
.
args
[
1
])
finally
:
if
txn
:
txn
.
abort
()
...
...
@@ -352,9 +352,9 @@ class bsdTableDB :
try
:
tcolpickles
=
self
.
db
.
get
(
_columns_key
(
table
))
except
DBNotFoundError
:
raise
TableDBError
,
"unknown table:
%
r"
%
(
table
,
)
raise
TableDBError
(
"unknown table:
%
r"
%
(
table
,)
)
if
not
tcolpickles
:
raise
TableDBError
,
"unknown table:
%
r"
%
(
table
,
)
raise
TableDBError
(
"unknown table:
%
r"
%
(
table
,)
)
self
.
__tablecolumns
[
table
]
=
pickle
.
loads
(
tcolpickles
)
def
__new_rowid
(
self
,
table
,
txn
)
:
...
...
@@ -388,14 +388,14 @@ class bsdTableDB :
txn
=
None
try
:
if
not
self
.
db
.
has_key
(
_columns_key
(
table
)):
raise
TableDBError
,
"unknown table"
raise
TableDBError
(
"unknown table"
)
# check the validity of each column name
if
table
not
in
self
.
__tablecolumns
:
self
.
__load_column_info
(
table
)
for
column
in
rowdict
.
keys
()
:
if
not
self
.
__tablecolumns
[
table
]
.
count
(
column
):
raise
TableDBError
,
"unknown column:
%
r"
%
(
column
,
)
raise
TableDBError
(
"unknown column:
%
r"
%
(
column
,)
)
# get a unique row identifier for this row
txn
=
self
.
env
.
txn_begin
()
...
...
@@ -419,7 +419,7 @@ class bsdTableDB :
txn
.
abort
()
self
.
db
.
delete
(
_rowid_key
(
table
,
rowid
))
txn
=
None
raise
TableDBError
,
dberror
.
args
[
1
],
info
[
2
]
raise
TableDBError
(
dberror
.
args
[
1
])
.
with_traceback
(
info
[
2
])
finally
:
if
txn
:
txn
.
abort
()
...
...
@@ -473,7 +473,7 @@ class bsdTableDB :
txn
.
abort
()
except
DBError
as
dberror
:
raise
TableDBError
,
dberror
.
args
[
1
]
raise
TableDBError
(
dberror
.
args
[
1
])
def
Delete
(
self
,
table
,
conditions
=
{}):
"""Delete(table, conditions) - Delete items matching the given
...
...
@@ -513,7 +513,7 @@ class bsdTableDB :
if
txn
:
txn
.
abort
()
except
DBError
as
dberror
:
raise
TableDBError
,
dberror
.
args
[
1
]
raise
TableDBError
(
dberror
.
args
[
1
])
def
Select
(
self
,
table
,
columns
,
conditions
=
{}):
...
...
@@ -533,7 +533,7 @@ class bsdTableDB :
columns
=
self
.
__tablecolumns
[
table
]
matching_rowids
=
self
.
__Select
(
table
,
columns
,
conditions
)
except
DBError
as
dberror
:
raise
TableDBError
,
dberror
.
args
[
1
]
raise
TableDBError
(
dberror
.
args
[
1
])
# return the matches as a list of dictionaries
return
matching_rowids
.
values
()
...
...
@@ -554,7 +554,7 @@ class bsdTableDB :
columns
=
self
.
tablecolumns
[
table
]
for
column
in
(
columns
+
list
(
conditions
.
keys
())):
if
not
self
.
__tablecolumns
[
table
]
.
count
(
column
):
raise
TableDBError
,
"unknown column:
%
r"
%
(
column
,
)
raise
TableDBError
(
"unknown column:
%
r"
%
(
column
,)
)
# keyed on rows that match so far, containings dicts keyed on
# column names containing the data for that row and column.
...
...
@@ -708,7 +708,7 @@ class bsdTableDB :
del
self
.
__tablecolumns
[
table
]
except
DBError
as
dberror
:
raise
TableDBError
,
dberror
.
args
[
1
]
raise
TableDBError
(
dberror
.
args
[
1
])
finally
:
if
txn
:
txn
.
abort
()
Lib/bsddb/test/test_basics.py
Dosyayı görüntüle @
a65e94c1
...
...
@@ -735,7 +735,7 @@ class BasicTransactionTestCase(BasicTestCase):
except
db
.
DBError
as
e
:
pass
else
:
raise
RuntimeError
,
"DBTxn.abort() called after DB_TXN no longer valid w/o an exception"
raise
RuntimeError
(
"DBTxn.abort() called after DB_TXN no longer valid w/o an exception"
)
txn
=
self
.
env
.
txn_begin
()
txn
.
commit
()
...
...
@@ -744,7 +744,7 @@ class BasicTransactionTestCase(BasicTestCase):
except
db
.
DBError
as
e
:
pass
else
:
raise
RuntimeError
,
"DBTxn.commit() called after DB_TXN no longer valid w/o an exception"
raise
RuntimeError
(
"DBTxn.commit() called after DB_TXN no longer valid w/o an exception"
)
class
BTreeTransactionTestCase
(
BasicTransactionTestCase
):
...
...
Lib/bsddb/test/test_compare.py
Dosyayı görüntüle @
a65e94c1
...
...
@@ -192,7 +192,7 @@ class BtreeExceptionsTestCase (AbstractBtreeKeyCompareTestCase):
if
l
==
r
:
# pass the set_bt_compare test
return
0
raise
RuntimeError
,
"i'm a naughty comparison function"
raise
RuntimeError
(
"i'm a naughty comparison function"
)
self
.
createDB
(
bad_comparator
)
#print "\n*** test should print 2 uncatchable tracebacks ***"
self
.
addDataToDB
([
'a'
,
'b'
,
'c'
])
# this should raise, but...
...
...
Lib/bsddb/test/test_dbtables.py
Dosyayı görüntüle @
a65e94c1
...
...
@@ -355,7 +355,7 @@ class TableDBTestCase(unittest.TestCase):
# success, the string value in mappings isn't callable
pass
else
:
raise
RuntimeError
,
"why was TypeError not raised for bad callable?"
raise
RuntimeError
(
"why was TypeError not raised for bad callable?"
)
# Delete key in select conditions
values
=
self
.
tdb
.
Select
(
...
...
Lib/bsddb/test/test_pickle.py
Dosyayı görüntüle @
a65e94c1
...
...
@@ -48,9 +48,9 @@ class pickleTestCase(unittest.TestCase):
#print repr(pickledEgg)
rottenEgg
=
pickle
.
loads
(
pickledEgg
)
if
rottenEgg
.
args
!=
egg
.
args
or
type
(
rottenEgg
)
!=
type
(
egg
):
raise
Exception
,
(
rottenEgg
,
'!='
,
egg
)
raise
Exception
(
rottenEgg
,
'!='
,
egg
)
else
:
raise
Exception
,
"where's my DBError exception?!?"
raise
Exception
(
"where's my DBError exception?!?"
)
self
.
db
.
close
()
self
.
env
.
close
()
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment