ruby-list

石橋秀仁です。こんにちは。自己レスです。

yaibaに入っているdoracle.rbは、Webアプリケーションサーバでいうところの
「DBコネクションプーリング機能」をdRubyサービスとして提供しています。
つまり、リモートホスト上でクエリを発行したり、その結果をRubyのArrayなどの
オブジェクトとして返したりできます。

コネクションプーリングの部分は他のソフトでも役に立ちそうなので、
抜き出して添付します。少し書き換えるといろいろと使えると思います。


添付サンプルの使い方：

at foo.hoge.jp
$ ruby doracle.rb
druby://foo.hoge.jp:17640

at bar.hoge.jp
$ ruby clnt.rb druby://foo.hoge.jp:17640
["00-09-05"]

注意）doracle.rbのDB接続が完了する前にclnt.rbを実行すると、
まだfoo.hoge.jpでdRubyサービスが立ち上がっていないので、
connection refusedになったりします。


カスタマイズの仕方：

ご使用の際は、Doracle#studentsのようなメソッドを、
アプリケーションに応じて追加することになります。
そのメソッドはクライアント側で、
  dqueue = DRbObject.new(nil, there)
  doracle = dqueue.pop
  result = doracle.students   # => Array or something
のように呼び出します。

yaibaでは、このWebアプリケーションサーバを、eRubyスクリプトから
呼び出しています。つまり、ネットワーク透過なので、将来的には
Gnutella方式みたいな分散DBにもしてみたいと思ってます :-)


Hideto ISHIBASHI <hideto-i@rr.iij4u.or.jp> wrote:

> yaiba (blade clone) のソースを公開します。
> http://www.rr.iij4u.or.jp/~hideto-i/rb/archive/yaiba-0.0.1.tar.gz

> 基本的にRDBMSと心中することになりました。Oracleで動いてます。
> PostgreSQLでも動かしたいです。PStore版も、たぶん動くと思いますけど。

--
石橋秀仁 hideto-i@rr.iij4u.or.jp
http://www.rr.iij4u.or.jp/~hideto-i/index.html

Attachments (4)

doracle.rb (2.49 KB, text/x-ruby)

# Copyright (c) 2000 Hideto "rubyholic" ISHIBASHI. All Rights Reserved.

require 'thread'
require 'singleton'
require 'oracle'
require 'drb/drb'
require 'drbrefid'


class DoracleQueue
  include DRbUndumped
  include Singleton

  def initialize
    @conf = Config.instance
    @user = @conf['doracle']['user']
    @passwd = @conf['doracle']['passwd']
    @service = @conf['doracle']['service']
    @minsvr = @conf['doracle']['minimum servers']
    @wait = @conf['doracle']['wait']
    @que = Queue.new
    @minsvr.times do @que.push(new_connection) end
    Thread.start { watch_loop }
  end

  def pop
    @que.pop
  end

 private
  def watch_loop
    loop do
      @que.push(new_connection) until @que.length == @minsvr
      sleep @wait
    end
  end

  def new_connection
    Doracle.new(@user, @passwd, @service)
  end
end



class Doracle
  include DRbUndumped

  def initialize(user, passwd, service)
    @conn = ::Oracle.new(user, passwd, service)
  end

  def terminate
    @conn.logoff
  end

=begin  # application specific methods... change as you like

  def students   # sample method
    retval = []
    begin
      cur = @conn.exec('select name from class_master')
      cur.fetch do |row|
        retval.push(row[0])
      end
    rescue OCIError
      p $!
    ensure
      cur.close
    end
    retval
  end

=end  # application specific methods... change as you like

  def exec(sql)
    retval = []
    begin
      cur = @conn.exec(sql)
      cur.fetch do |row|
        retval.push(row[0])
      end
    rescue OCIError
      p $!
    ensure
      cur.close
    end
    retval
  end

end



class Config
  # system-wide configuration like Windows' registories

  include Singleton

  def initialize
    @hash = Hash.new   # { 'conf name' => 'value', 'foo' => 5, ... }
    @mutex = Mutex.new
  end

  def store(key, value)
    @mutex.synchronize do
      @hash.store(key, value)
    end
  end
  alias []= store

  def fetch(key)
    @mutex.synchronize do
      @hash.fetch(key)
    end
  end
  alias [] fetch
end



if __FILE__ == $0
  Thread.abort_on_exception = true

  # config
  eval(File.open('conf.rb').read)
  conf = Config.instance
  uri = conf['doracle']['druby uri']
  tout = conf['doracle']['druby timeout']
  print(uri, "\n")

  # daemon
  pid = fork
  if pid.nil?
    # child process
    $stdout.close
    $stdin.close
    $stderr.close

    queue = DoracleQueue.instance

    DRb.install_id_conv(DRbRefIdConv.new(tout))
    DRb.start_service(uri, queue)

    DRb.thread.join
  end
  # parent process
  exit 0
end

drbrefid.rb (896 Bytes, text/x-ruby)

require 'thread'

class DRbRefIdConv

  def initialize(time_to_live)
    @time_to_live = time_to_live
    @thr_table = {}     # {id => object}
    @obj_table = {}     # {id => killer thread}
    @thr_sync = Mutex.new
    @obj_sync = Mutex.new
  end

  def to_obj(id)
    obj = ObjectSpace._id2ref(id)
    set_killer(id)
    reset_obj(id, obj)
    obj
  end

  def to_id(obj)
    id = obj.id
    set_killer(id)
    reset_obj(id, obj)
    id
  end

  # note: set_killer before reset_obj
  def reset_obj(id, obj)
    @obj_sync.synchronize do
      @obj_table[id] = obj
    end
  end

 private
  def set_killer(id)     # reset killer
    @thr_sync.synchronize do
      thr = @thr_table[id]
      Thread.kill(thr) if thr
      @thr_table[id] = killer(id)
    end
  end

  def killer(id)
    Thread.start do
      sleep(@time_to_live)
      reset_obj(id, nil)  # remove id from table
    end
  end
end

conf.rb (362 Bytes, text/x-ruby)

# configuration file: Ruby script file

parameters = {
  'doracle' => {
    'user' => 'kumo',
    'passwd' => 'kumosuke',
    'service' => 'fire',
    'minimum servers' => 5,
    'wait' => 0.1,
    'druby uri' => 'druby://localhost:17640',
    'druby timeout' => 30,  # second
  },
}

parameters.each_pair do |key, value|
  Config.instance.store(key, value)
end

clnt.rb (258 Bytes, text/x-ruby)

require 'drbrefid'
require 'drb/drb'

there = ARGV.shift
unless there
  $stderr.puts("usage: #{$0} <server_uri>")
  exit 1
end

DRb.start_service
doracle = DRbObject.new(nil, there)
conn = doracle.pop
result = conn.exec('select sysdate from dual')
p result

Thread

Prev Next

In This Thread

Prev Next

[#24691] — Yasushi ABE (阿部 靖司) <yasushi@...>

[#24702] socket が動きません (rbcw146 on WinNT4SP6) — TAKEUCHi Kahori <takeuchi@...>

[#24705] yaiba (blade clone) 0.0.1 — Hideto ISHIBASHI <hideto-i@...4u.or.jp>

[#24707] Re: yaiba (blade clone) 0.0.1 — "Okada Jun" <yun@...>

[#24711] win32 で RDtool — Kazuhiro NISHIYAMA <zn@...>

[#24723] termios はいずこ ? — eda@...

[#24727] priority queue — "K.Kodama" <kdm@...>

[#24729] Net::IMAP — Shugo Maeda <shugo@...>

[#24731] win32 Time zone — Kazuhiro Yoshida <moriq.kazuhiro@...>

[#24738] what's new — Minero Aoki <aamine@...>

[#24798] (RDP) mkmf.rb — Koji Arai <JCA02266@...>

[#24804] ruby-mode (Re: [ruby-dev:10833] Re: ruby 1.6.0 preview2) — Ryunosuke Ohshima <ryu@...>

[#24820] strscan in raa — rubikitch <rubikitch@...>

[#24883] Rd2 用のフォーマットファイル — tkadowak@...

[#24892] rd-mode.el — rubikitch <rubikitch@...>

[#24895] Hello and Gtk::CTree — KUNISAWA Keita <kunisawa@...>

[#24897] — "Hideyuki Hirauchi" <hirauchi@...>

[#24904] UDPSocket の送信元ポート番号の指定 — HiroshiSaito@...

[#24911] PostgreSQL In CGI — Takayuki Tanaka <tanaka@...>

[#24917] DRbAuth — Masatoshi SEKI <m_seki@...>

[#24919] Re: file から読み込んだ文字列の #{} — Wakou Aoyama <wakou@...>

[#24920] Re: Status: header and cgi.rb — Wakou Aoyama <wakou@...>

[#24921] 正規表現の {,n} — Kazuhiro NISHIYAMA <zn@...>

[#24926] win32 版での TCPServer#addr, peeraddr の挙動 — OGATA Daisuke <Daisuke.Ogata@...>

[#24927] system 関数について — "ISIHARA HIROSI" <ishihara-h@...>

[#24931] Win 上で PostgreSQL にアクセス — Yasuki <yasuki@...>

[#24933] Re: Status: header and cgi.rb — Wakou Aoyama <wakou@...>

[#24937] Re: system 関数について — "ISIHARA HIROSI" <ishihara-h@...>

[#24938] Bignum の不具合 — Yasumasa Fujisawa <yfuji@...>

[#24939] re: Win 上で PostgreSQL にアクセス — tamra@...

[#24940] HTML to MAIL — Makoto Ozawa <ozawa@...>

[#24948] Re: Bignum の不具合 — Yasumasa Fujisawa <yfuji@...>

[#24949] mswin32 組み込み用 Ruby — toyofuku@...

[#24953] SEA wakate 2000 — matz@... (Yukihiro Matsumoto)

[#24955] Re: mswin32 組み込み用 Ruby — Toyofuku <toyofuku@...>

[#24958] Installer test: ruby-1.6.0-preview — ARIMA Yasuhiro <fit0298@...>

[#24960] TMail MboxLoader can't work — kenn@...

[#24962] Pigeon — Kazuhiro Yoshida <moriq.kazuhiro@...>

[#24966] Re: Any Ruby download statistics available? — ARIMA Yasuhiro <fit0298@...>

[#24968] media watch 2000.09.18 — Noritsugu Nakamura <nnakamur@...>

[#24969] UDPsocket#send <boradcast> でエラー — Hiroshi Saito <HiroshiSaito@...>

[#24972] server maintenance — Shugo Maeda <shugo@...>

[#24973] How to check all Thread fin ? — Sakae Kobayashi <sakae@...>

[#24976] Re: [ruby-dev:10974] drb-1.2.2 (Re: require "marshal" failure) — Masatoshi SEKI <m_seki@...>

[#24978] ANNOUNCE: Ruby 1.6.0 — matz@... (Yukihiro Matsumoto)

[#24983] install guide, small faults — SUGIHARA Hiroshi <maili31s@...>

[#24985] Ruby 1.6.0 の変更点 — matz@... (Yukihiro Matsumoto)

[#24986] Ruby 1.6.0 の変更点 — matz@... (Yukihiro Matsumoto)

[#24988] ruby-1.6.0-i586-beos-socket — Katsuyuki Komatsu <komatsu@...>

[#24991] Windows 環境での、 mod_ruby の作り方。 — ohara@...

[#25013] file separator for Ruby in Windows — TAKAHASHI Masayoshi <maki@...>

[#25025] build 1.6.0 on Tru64 (zipped SJIS file attached) — maili31s@... (SugHimsi)

[#25036] install guide draft for IRIX64 — Katsuyuki Komatsu <komatsu@...>

[#25039] ruby1.6.0 Darwin Patch — SHIROYAMA Takayuki <psi@...>

[#25040] Re: file separator for Ruby in Windows — 小野工場設計部 <ind.onosetu1@...>

[#25054] Re: mswin32 組み込み用 Ruby — Toyofuku <toyofuku@...>

[#25055] What is this animal? — OZAWA -Crouton- Sakuro <crouton@...>

[#25063] ruby 1.6.0 and xmlparser — Hiroyuki KUROSAKI <noir@...>

[#25067] build 1.6.0 on sparc-sun-solaris2.8 — wind@... (Suzuki Hisao/鈴木永夫)

[#25077] Ruby Entry Package ( ruby-1.6.1-mingw ) — ARIMA Yasuhiro <fit0298@...>

[#25084] configure で --with-sitedir が効かなくなる — Tatsuya BIZENN <bizenn@...>

[#25091] ext/tcltklib/extconf.rb — "DATE Ken" <ge6537@...>

[#25092] http-access の get_data の指定サイズ — Makoto Ozawa <ozawa@...>

[#25109] assoc to rubyw.exe — ARIMA Yasuhiro <fit0298@...>

[#25130] Re: How to check all Thread fin ? — Aleksi Niemela <aleksi.niemela@...>

[#25134] Ruby 本と 1.6.x — arton <arton@...>

[#25138] I want GC.report — Sakae Kobayashi <sakae@...>

[#25143] ruby cal.rb on win32 — Kazuhiro Yoshida <moriq.kazuhiro@...>

[#25147] media watch 2000.08.24 — Noritsugu Nakamura <nnakamur@...>

[#25165] snprintf in regex.c — arton <arton@...>

[#25169] priority & ThreadGroup (Re: [ruby-dev:9438] Re: $SAFE) — Masatoshi SEKI <m_seki@...>

[#25172] round method — WATABE Eiji <eiji@...>

[#25191] 1.4 から 1.6 までに予約語の追加削除等ありますか？ — 綾乃介 <aya@...>

[#25194] The latest FreeBSD ports list — "Akinori -Aki- MUSHA" <knu@...>

[#25199] test — Shugo Maeda <shugo@...>

[#25201] Ruby/mSQL — "DATE Ken" <ge6537@...>

[#25204] ANNOUNCE: Ruby 1.6.1 — matz@... (Yukihiro Matsumoto)

[#25209] Re: ANNOUNCE: Ruby 1.6.1 — SHIROYAMA Takayuki <psi@...>

[#25210] Find module — Ryuichi Tamura <tam@...>

[#25222] Programming Ruby — TAKAHASHI Masayoshi <maki@...>

[#24691] — Yasushi ABE (阿部靖司) <yasushi@...>