ruby-list

Fri, 27 Apr 2001 00:54:15 +0900 頃の
   Mail-Count: 29431
      Subject: [ruby-list:29431] Re: [ruby-ext:01642] Re: o_dbm   
についてのお話にて 石塚圭樹  さん曰く… 
(石 == keiju@ishitsuka.com (石塚圭樹) さん)

>> この「微妙な問題」というのはどういうものですか?

In article 29431, <200104261245.VAA10795.keiju@ishitsuka.com>
石> メモリ中のオブジェクトとデータベースから持ってきたオブジェクトが実際には
石> 同じじゃないってことかしら...

なるほど. 注意が必要ですね. 

>>>> あと require "dbm" ですが gdbm でも動作するようなので
>>>> どっちかえらべるとうれしいかもしれないと思うのですがどうでしょうか. 

bdbをうまく使ってやるとロックとかうまく扱えそうな感じがしますね. 

というか, なんとかEX/SHロックをかけられるようにならないかと
いろいろ—ロックファイルを使って…とかもやってみたんですが, 
結局DBM/GDBMでは難しいなあというところで落ち着きました. 
# BDB_Adapterを作って, それならロックもいけるよ
# というのに挑戦するのがまっとうかなあ, と. 

ただ, その過程でいくつかbugらしきものを見付けたので
patchを作ってみました. いかがでしょうか. 

-- 

 やまだ あきら <URL:http://arika.org/>
 (akira@arika.org, akira@ruby-lang.org or akira@ad-hoc.org)

--- /usr/lib/ruby/1.6/o_dbm.rb	Tue Apr 24 23:02:41 2001
+++ o_dbm.rb	Tue May  1 10:59:38 2001
@@ -181,9 +181,9 @@
 
   def root_names
     keys = []
-    each_keys do
+    each_key do
       |key|
-      keys.push = keys
+      keys.push(key)
     end
     keys
   end
@@ -191,7 +191,7 @@
 
   def size
     no = 0
-    each_keys do
+    each_key do
       |key|
       no += 1
     end
@@ -286,7 +286,7 @@
     if mode != SCAN_CACHE_ONLY
       @db.each_key do
 	|key|
-	yield key unless mode == SCANL_DB_ONLY or @read_cache[key] == NULL
+	yield key if mode == SCAN_DB_ONLY or @read_cache[key] == NULL
       end
     end
   end
@@ -327,8 +327,8 @@
       end
       @transaction_mode = STATIC_TRANSACTION_MODE
       @current_transaction = StaticTransaction.new(self, mode, outer)
-      @current_transaction.transaction do
-	yield @current_transaction
+      @current_transaction.transaction do |current_transaction|
+	yield current_transaction
       end
     else
       if @transaction_mode == STATIC_TRANSACTION_MODE
@@ -368,8 +368,7 @@
       txn.outer.write_cache = txn.write_cache.dup
       txn.outer.delete_cache = txn.delete_cache.dup
     else
-      close(HOLD_READ_CACHE)
-      @db = @db_adapter.open(@db_name)
+      flush_db
     end
   end
   
@@ -418,6 +417,7 @@
     for key, value in @write_cache
       @db[key] = Marshal.dump(value)
     end
+    @db.commit
     @write_cache.clear
   end
   private :flush_db
@@ -511,7 +511,7 @@
     def transaction
       @status = START
       begin
-	txn, value = catch(ABORT_LABEL){[nil, yield(@current_transaction)]}
+	txn, value = catch(ABORT_LABEL){[nil, yield(self)]}
 	if txn
 	  @status = ABORTING
 	  unless txn.equal?(self)
@@ -552,7 +552,7 @@
     def checkpoint
       case @status
       when START
-	@odbm.flush(txn)
+	@odbm.flush(self)
       when COMMITED, ABORTED
 	Transaction.Fail ErrClosedTransaction
       end
@@ -637,7 +637,7 @@
 
     # store value with <key>
     def []=(key, value)
-      ODBM.Fail ErrAdapterInterfaceNotImplement, "[]"
+      ODBM.Fail ErrAdapterInterfaceNotImplement, "[]="
     end
 
     def has_key?(key)
@@ -665,6 +665,11 @@
       ODBM.Fail ErrAdapterInterfaceNotImplement, "delete"
     end
 
+    # commit database
+    def commit
+      ODBM.Fail ErrAdapterInterfaceNotImplement, "commit"
+    end
+
     # close database
     def close
       ODBM.Fail ErrAdapterInterfaceNotImplement, "close"
@@ -674,6 +679,10 @@
   autoload :DBM, "dbm"
   class DBM_Adapter<DB_Adapter
     def self.open(name)
+      new(name)
+    end
+
+    def initialize(name)
       @db = DBM.open(name)
     end
 
@@ -682,7 +691,7 @@
     end
 
     def []=(key, value)
-      @db[key] = valuep
+      @db[key] = value
     end
 
     def key?(key)
@@ -701,7 +710,16 @@
       @db.each_value &block
     end
 
+    def delete(key)
+      @db.delete(key)
+    end
+
+    def commit
+      # noop
+    end
+
     def close
+      commit
       @db.close
       @db = nil
     end
@@ -709,48 +727,69 @@
 
   autoload :GDBM, "gdbm"
   class GDBM_Adapter<DBM_Adapter
-    def self.open(name)
+    def initialize(name)
       @db = GDBM.open(name)
     end
   end
 
   autoload :SDBM, "sdbm"
   class SDBM_Adapter<DBM_Adapter
-    def self.open(name)
+    def initialize(name)
       @db = SDBM.open(name)
     end
   end
 
   class PHash_Adapter<DB_Adapter
     def self.open(name)
+      new(name)
+    end
+
+    def initialize(name)
       @db_name = name
-      @db = File.open(name)
-      ODBM.Fail ErrAdapterInterfaceNotImplement, "open"
+      if File.exist?(name)
+        file = File::open(name, 'r')
+	begin
+	  @hash = Marshal.load(file)
+	ensure
+	  file.close
+	end
+      else
+        @hash = {}
+      end
     end
 
     # restore value with <key> 
     def [](key)
-      ODBM.Fail ErrAdapterInterfaceNotImplement, "[]"
+      @hash[key]
     end
 
     # store value with <key>
     def []=(key, value)
-      ODBM.Fail ErrAdapterInterfaceNotImplement, "[]"
+      @hash[key] = value
     end
 
     # access all keys in database.
     def each_key(&block)
-      ODBM.Fail ErrAdapterInterfaceNotImplement, "each_key"
+      @hash.each_key {|key| block.call(key)}
     end
 
     # delete value with <key>
     def delete(key)
-      ODBM.Fail ErrAdapterInterfaceNotImplement, "delete"
+      @hash.delete(key)
+    end
+
+    # commit database
+    def commit
+      newfile = @db_name + '.new'
+      file = open(newfile, 'w')
+      Marshal.dump(@hash, file)
+      file.close
+      File.rename(newfile, @db_name)
     end
 
     # close database
     def close
-      ODBM.Fail ErrAdapterInterfaceNotImplement, "close"
+      commit
     end
   end
 end

Thread

Prev Next

In This Thread

Prev Next

[#29469] エラーを捕まえたいのですが ... — Sakae Kobayashi <sakae@...>

[#29471] rd2man について — "NAITOH Jun" <naitoh@...>

[#29476] Re: rd2man について — "NAITOH Jun" <naitoh@...>

[#29478] Re: rd2man について — "NAITOH Jun" <naitoh@...>

[#29480] xpstore — akira yamada / やまだあきら <akira@...>

[#29487] Re: rd2man について — "NAITOH Jun" <naitoh@...>

[#29490] Re: [ruby-talk:14555] Ruby as a Mac OS/X scripting language — maili31s@... (SugHimsi == SUGIHARA Hiroshi)

[#29504] クラスブラウザ with ReFe — kadu <kadu3@...16.alpha-net.ne.jp>

[#29513] drb-1.3.2 — Masatoshi SEKI <m_seki@...>

[#29514] （ a -2) と (100 -2) の違いは — 島田 喜郎 <yoshimada@...>

[#29517] Re: [ruby-talk:14537] Rajah: Ruby-Java integration — maili31s@... (SugHimsi == SUGIHARA Hiroshi)

[#29520] Re: （ a -2) と (100 -2) の違いは — 島田 喜郎 <yoshimada@...>

[#29521] A problem with the latest irb — "Akinori MUSHA" <knu@...>

[#29524] tr range? — kiri@...

[#29525] pstore でエラー — 堀川 久 <vzw00011@...>

[#29542] MWDOM-0.1 released — MoonWolf <moonwolf@...>

[#29544] enriching standard extention libraries: syslog, zlib, etc. — "Akinori MUSHA" <knu@...>

[#29547] strftime.c でのエラー — "Kazuaki Miyauchi" <miyauchk@...>

[#29550] UDP でバイナリデータを送りたいのですが？ — "Kenji Takahashi" <kenji4553@...>

[#29571] cgi/auth — akira yamada / やまだあきら <akira@...>

[#29584] [BUG?] Thread の終了時に Thread.critical が解除されない。 — "Okada Jun" <yun@...>

[#29587] duplicate fragment identifiers in ruby-refm.html — Tanaka Akira <akr@...17n.org>

[#29596] Re: [BUG?] Thread の終了時に Thread.critical が解除されない。 — "Okada Jun" <yun@...>

[#29597] media watch 2001.05.08 — Noritsugu Nakamura <nnakamur@...>

[#29603] Importing shell.rb — "Akinori MUSHA" <knu@...>

[#29604] Importing eachdelegator.rb — "Akinori MUSHA" <knu@...>

[#29616] RDtool-0.6.8 — rubikitch <rubikitch@...>

[#29617] Ruby/SDL Watch(2000-05-10) — tamra@...

[#29633] Re: [ruby-talk:14973] OOPSLA news — keiju@... (Keiju ISHITSUKA)

[#29638] クラスブラウザ with ri — kadu <kadu3@...16.alpha-net.ne.jp>

[#29639] rdtool 0.6.8 — "Akinori MUSHA" <knu@...>

[#29640] string joining with O(n) — Tanaka Akira <akr@...17n.org>

[#29644] rwiki.rb でエラー — norio goto <goto@...>

[#29647] String#index — OHARA Shigeki <os@...>

[#29653] Do you have any question about 256 book? — Masaki Suketa <masaki.suketa@...>

[#29657] media watch (情処) — Noritsugu Nakamura <nnakamur@...>

[#29665] frozen string in a |= b — kiri@...

[#29666] Re: Enumerator — "Okada Jun" <yun@...>

[#29674] Re: Enumerator — "Okada Jun" <yun@...>

[#29675] with(obj){ } が欲しい。 — Take_tk <ggb03124@...>

[#29689] 日付文字列から時間を得る — masahiro kawata <mas@...>

[#29696] RDtool 0.6.8 is very slow — WATANABE Hirofumi <eban@...>

[#29707] OBJECT DAY2001 — "K.Kosako" <kosako@...>

[#29709] Re: OBJECT DAY2001 — NAWATE Masahiko <agul@...>

[#29720] rand(1<<32) — TAKEUCHI Hideki <take@...>

[#29721] Cygwin で Ruby をコンパイルするとエラーがでます。 — "Inoue" <inoue@...>

[#29743] Re: Cygwin で Ruby をコンパイルするとエラーがでます。 — kiri@...

[#29744] about CGI::Cookie::new — norio goto <goto@...>

[#29755] http.rb と IIS — Hironori Ohtsubo <ohtsubo@...>

[#29759] WinNT Ruby CGI KILL? — "Inoue" <inoue@...>

[#29764] URb 0.2 — akira yamada / やまだあきら <akira@...>

[#29766] インストールができません。 — Jun-ichi Murakoshi <murakosi@...>

[#29786] 256+ 倍本 get — Noritsugu Nakamura <nnakamur@...>

[#29788] marshaled time format differ — IWATSUKI Hiroyuki <don@...>

[#29793] Ruby/SDL 0.6 — ohai@... (Ippei Obayashi)

[#29812] A request to RAA (was Re: YARPC 19101) — Takahiro Kambe <taca@...>

[#29824] Windows 版 Ruby — "U.Nakamura" <usa@...>

[#29841] [Q] "can't clone" error — HISANO Kozo <mail@...>

[#29847] MWDOM-0.1.5 released — MoonWolf <moonwolf@...>

[#29853] "" で行われる展開を eval 無しで… — ABE Shigeru <shiger-a@...>

[#29864] ActiveScriptRuby について質問です — たくみ <taku3@...>

[#29866] FileUpload CGI — "takashi Yamaoka" <t_yamashita@...>

[#29871] Re: rd2man について — "NAITOH Jun" <naitoh@...>

[#29880] autoconf.rb — nobu.nakada@...

[#29886] mod_ruby and eruby — norio goto <goto@...>

[#29894] module::method() と methid() の違いは ? — 岡 保嗣 <oka@...>

[#29897] tsort.rb — "Akinori MUSHA" <knu@...>

[#29898] /src/rough — "Akinori MUSHA" <knu@...>

[#29901] Re: module::method() と methid() の違いは ? — 岡 保嗣 <oka@...>

[#29910] Re: module::method() と methid() の違いは ? — 岡 保嗣 <oka@...>

[#29911] w3m のコンパイルエラーが起きました — "Inoue" <inoue@...>

[#29913] Ruby-1.6.3 Win32 版コンパイル・リンクに失敗してます — TakahashiMa@...

[#29915] 私のモジュールの使い方は間違ってる ? — 岡 保嗣 <oka@...>

[#29920] ☆彡 (- 人 -;) 願い事願い事 ... — 熊谷のAkira@... <aan82580@...>

[#29921] RE: ☆彡 (- 人 -;) 願い事願い事 ... — 野原 正樹 <Masaki.Nohara@...>

[#29922] Re: ☆彡 (- 人 -;) 願い事願い事 ... — 岡 保嗣 <oka@...>

[#29926] Re: Ruby-1.6.3 Win32 版コンパイル・リンクに失敗してます — TakahashiMa@...

[#29935] Re: 私のモジュールの使い方は間違ってる ? — 岡 保嗣 <oka@...>

[#29936] Re: Ruby-1.6.3 Win32 版コンパイル・リンクに失敗してます — TakahashiMa@...

[#29939] Re: 私のモジュールの使い方は間違ってる ? — 岡 保嗣 <oka@...>

[#29514] （ a -2) と (100 -2) の違いは — 島田喜郎 <yoshimada@...>

[#29520] Re: （ a -2) と (100 -2) の違いは — 島田喜郎 <yoshimada@...>

[#29525] pstore でエラー — 堀川久 <vzw00011@...>

[#29894] module::method() と methid() の違いは ? — 岡保嗣 <oka@...>

[#29901] Re: module::method() と methid() の違いは ? — 岡保嗣 <oka@...>

[#29910] Re: module::method() と methid() の違いは ? — 岡保嗣 <oka@...>

[#29915] 私のモジュールの使い方は間違ってる ? — 岡保嗣 <oka@...>

[#29921] RE: ☆彡 (- 人 -;) 願い事願い事 ... — 野原正樹 <Masaki.Nohara@...>

[#29922] Re: ☆彡 (- 人 -;) 願い事願い事 ... — 岡保嗣 <oka@...>

[#29935] Re: 私のモジュールの使い方は間違ってる ? — 岡保嗣 <oka@...>

[#29939] Re: 私のモジュールの使い方は間違ってる ? — 岡保嗣 <oka@...>

[#29946] Re: module::method() と methid() の違いは ? — 岡保嗣 <oka@...>