doc/classes/TokyoTyrant/RDBQRY.src/M000060.html @@ -13,6 +13,7 @@ <pre># File tokyotyrant.rb, line 58 def initialize() @ecode = ESUCCESS + @enc = nil @sock = nil end</pre> </body> doc/classes/TokyoTyrant/RDB.src/M000009.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 65 + <pre># File tokyotyrant.rb, line 66 def errmsg(ecode = nil) ecode = @ecode if !ecode if ecode == ESUCCESS doc/classes/TokyoTyrant/RDB.src/M000010.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 91 + <pre># File tokyotyrant.rb, line 92 def ecode() return @ecode end</pre> doc/classes/TokyoTyrant/RDB.src/M000011.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 98 + <pre># File tokyotyrant.rb, line 99 def open(host, port = 0) host = _argstr(host) port = _argnum(port) @@ -31,6 +31,10 @@ @ecode = EREFUSED return false end + begin + sock.setsockopt(Socket::IPPROTO_TCP, Socket::TCP_NODELAY, true) + rescue Exception + end else begin sock = UNIXSocket.open(host) @@ -39,6 +43,9 @@ return false end end + if sock.respond_to?(:set_encoding) + sock.set_encoding("ASCII-8BIT") + end @sock = sock return true end</pre> doc/classes/TokyoTyrant/RDB.src/M000012.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 131 + <pre># File tokyotyrant.rb, line 139 def close() if !@sock @ecode = EINVALID doc/classes/TokyoTyrant/RDB.src/M000013.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 151 + <pre># File tokyotyrant.rb, line 159 def put(key, value) key = _argstr(key) value = _argstr(value) doc/classes/TokyoTyrant/RDB.src/M000014.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 180 + <pre># File tokyotyrant.rb, line 188 def putkeep(key, value) key = _argstr(key) value = _argstr(value) doc/classes/TokyoTyrant/RDB.src/M000015.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 209 + <pre># File tokyotyrant.rb, line 217 def putcat(key, value) key = _argstr(key) value = _argstr(value) doc/classes/TokyoTyrant/RDB.src/M000016.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 239 + <pre># File tokyotyrant.rb, line 247 def putshl(key, value, width = 0) key = _argstr(key) value = _argstr(value) doc/classes/TokyoTyrant/RDB.src/M000017.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 269 + <pre># File tokyotyrant.rb, line 277 def putnr(key, value) key = _argstr(key) value = _argstr(value) doc/classes/TokyoTyrant/RDB.src/M000018.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 287 + <pre># File tokyotyrant.rb, line 295 def out(key) key = _argstr(key) if !@sock doc/classes/TokyoTyrant/RDB.src/M000019.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 313 + <pre># File tokyotyrant.rb, line 321 def get(key) key = _argstr(key) sbuf = [0xC8, 0x30, key.length].pack("CCN") @@ -38,7 +38,7 @@ @ecode = ERECV return nil end - return vbuf + return _retstr(vbuf) end</pre> </body> </html> doc/classes/TokyoTyrant/RDB.src/M000020.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 345 + <pre># File tokyotyrant.rb, line 353 def mget(recs) raise ArgumentError if !recs.is_a?(Hash) if !@sock @@ -57,7 +57,7 @@ @ecode = ERECV return -1 end - recs[kbuf] = vbuf + recs[kbuf] = _retstr(vbuf) end return rnum end</pre> doc/classes/TokyoTyrant/RDB.src/M000021.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 398 + <pre># File tokyotyrant.rb, line 406 def vsiz(key) key = _argstr(key) if !@sock doc/classes/TokyoTyrant/RDB.src/M000022.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 424 + <pre># File tokyotyrant.rb, line 432 def iterinit() if !@sock @ecode = EINVALID doc/classes/TokyoTyrant/RDB.src/M000023.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 448 + <pre># File tokyotyrant.rb, line 456 def iternext() if !@sock @ecode = EINVALID @@ -40,7 +40,7 @@ @ecode = ERECV return nil end - return vbuf + return _retstr(vbuf) end</pre> </body> </html> doc/classes/TokyoTyrant/RDB.src/M000024.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 484 + <pre># File tokyotyrant.rb, line 492 def fwmkeys(prefix, max = -1) prefix = _argstr(prefix) max = _argnum(max) @@ -50,7 +50,7 @@ @ecode = ERECV return Array.new end - keys.push(kbuf) + keys.push(_retstr(kbuf)) end return keys end</pre> doc/classes/TokyoTyrant/RDB.src/M000025.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 532 + <pre># File tokyotyrant.rb, line 540 def addint(key, num = 0) key = _argstr(key) num = _argnum(num) doc/classes/TokyoTyrant/RDB.src/M000026.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 561 + <pre># File tokyotyrant.rb, line 569 def adddouble(key, num) key = _argstr(key) num = _argnum(num) doc/classes/TokyoTyrant/RDB.src/M000027.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 595 + <pre># File tokyotyrant.rb, line 603 def ext(name, key = "", value = "", opts = 0) name = _argstr(name) key = _argstr(key) @@ -45,7 +45,7 @@ @ecode = ERECV return nil end - return vbuf + return _retstr(vbuf) end</pre> </body> </html> doc/classes/TokyoTyrant/RDB.src/M000028.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 633 + <pre># File tokyotyrant.rb, line 641 def sync() if !@sock @ecode = EINVALID doc/classes/TokyoTyrant/RDB.src/M000029.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 656 + <pre># File tokyotyrant.rb, line 664 def vanish() if !@sock @ecode = EINVALID doc/classes/TokyoTyrant/RDB.src/M000030.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 681 + <pre># File tokyotyrant.rb, line 689 def copy(path) path = _argstr(path) if !@sock doc/classes/TokyoTyrant/RDB.src/M000031.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 706 + <pre># File tokyotyrant.rb, line 714 def rnum() if !@sock @ecode = EINVALID doc/classes/TokyoTyrant/RDB.src/M000032.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 729 + <pre># File tokyotyrant.rb, line 737 def size() if !@sock @ecode = EINVALID doc/classes/TokyoTyrant/RDB.src/M000033.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 752 + <pre># File tokyotyrant.rb, line 760 def stat() if !@sock @ecode = EINVALID @@ -40,7 +40,7 @@ @ecode = ERECV return nil end - return sbuf + return _retstr(sbuf) end</pre> </body> </html> doc/classes/TokyoTyrant/RDB.src/M000034.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 788 + <pre># File tokyotyrant.rb, line 796 def misc(name, args = [], opts = 0) name = _argstr(name) args = Array.new if !args.is_a?(Array) @@ -51,7 +51,7 @@ @ecode = ERECV return nil end - res.push(ebuf) + res.push(_retstr(ebuf)) end return res end</pre> doc/classes/TokyoTyrant/RDB.src/M000035.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 838 + <pre># File tokyotyrant.rb, line 846 def store(key, value) return put(key, value) end</pre> doc/classes/TokyoTyrant/RDB.src/M000036.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 843 + <pre># File tokyotyrant.rb, line 851 def delete(key) return out(key) end</pre> doc/classes/TokyoTyrant/RDB.src/M000037.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 848 + <pre># File tokyotyrant.rb, line 856 def fetch(key) return out(key) end</pre> doc/classes/TokyoTyrant/RDB.src/M000038.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 853 + <pre># File tokyotyrant.rb, line 861 def has_key?(key) return vsiz(key) >= 0 end</pre> doc/classes/TokyoTyrant/RDB.src/M000039.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 858 + <pre># File tokyotyrant.rb, line 866 def has_value?(value) return nil if !iterinit while tkey = iternext doc/classes/TokyoTyrant/RDB.src/M000040.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 869 + <pre># File tokyotyrant.rb, line 877 def clear return vanish end</pre> doc/classes/TokyoTyrant/RDB.src/M000041.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 874 + <pre># File tokyotyrant.rb, line 882 def length return rnum end</pre> doc/classes/TokyoTyrant/RDB.src/M000042.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 879 + <pre># File tokyotyrant.rb, line 887 def empty? return rnum > 0 end</pre> doc/classes/TokyoTyrant/RDB.src/M000043.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 884 + <pre># File tokyotyrant.rb, line 892 def []=(key, value) return put(key, value) end</pre> doc/classes/TokyoTyrant/RDB.src/M000044.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 889 + <pre># File tokyotyrant.rb, line 897 def [](key) return get(key) end</pre> doc/classes/TokyoTyrant/RDB.src/M000045.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 894 + <pre># File tokyotyrant.rb, line 902 def each return nil if !iterinit while key = iternext doc/classes/TokyoTyrant/RDB.src/M000046.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 906 + <pre># File tokyotyrant.rb, line 914 def each_keys return nil if !iterinit while key = iternext doc/classes/TokyoTyrant/RDB.src/M000048.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 915 + <pre># File tokyotyrant.rb, line 923 def each_values return nil if !iterinit while key = iternext doc/classes/TokyoTyrant/RDB.src/M000049.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 926 + <pre># File tokyotyrant.rb, line 934 def keys tkeys = Array.new return tkeys if !iterinit doc/classes/TokyoTyrant/RDB.src/M000050.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 936 + <pre># File tokyotyrant.rb, line 944 def values tvals = Array.new return tvals if !iterinit doc/classes/TokyoTyrant/RDB.src/M000051.html @@ -96,6 +96,7 @@ href="RDBTBL.html">TokyoTyrant::RDBTBL</a>". <a href="#M000054">addcond</a>   <a href="#M000052">new</a>   <a href="#M000057">search</a>   + <a href="#M000060">searchcount</a>   <a href="#M000059">searchget</a>   <a href="#M000058">searchout</a>   <a href="#M000056">setlimit</a>   @@ -438,6 +439,24 @@ never fail and return an empty array even if no record corresponds. </div> </div> + <div id="method-M000060" class="method-detail"> + <a name="M000060"></a> + + <div class="method-heading"> + <a href="RDBQRY.src/M000060.html" target="Code" class="method-signature" + onclick="popupCode('RDBQRY.src/M000060.html');return false;"> + searchcount() + </a> + </div> + + <div class="method-description"> + +Get the count of corresponding records. The return value is the count of +corresponding records or 0 on failure. + + </div> + </div> + <div id="method-M000059" class="method-detail"> <a name="M000059"></a> doc/classes/TokyoTyrant/RDBQRY.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1200 + <pre># File tokyotyrant.rb, line 1237 def initialize(rdb) raise ArgumentError if !rdb.is_a?(TokyoTyrant::RDBTBL) @rdb = rdb doc/classes/TokyoTyrant/RDBQRY.src/M000052.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1204 + <pre># File tokyotyrant.rb, line 1241 def self.setmax(max) # for backward compatibility setlimit(max) end</pre> doc/classes/TokyoTyrant/RDBQRY.src/M000053.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1213 + <pre># File tokyotyrant.rb, line 1250 def addcond(name, op, expr) @args.push("addcond" + "\0" + name + "\0" + op.to_s + "\0" + expr) return nil doc/classes/TokyoTyrant/RDBQRY.src/M000054.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1221 + <pre># File tokyotyrant.rb, line 1258 def setorder(name, type) @args.push("setorder" + "\0" + name + "\0" + type.to_s) return nil doc/classes/TokyoTyrant/RDBQRY.src/M000055.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1229 + <pre># File tokyotyrant.rb, line 1266 def setlimit(max = -1, skip = -1) @args.push("setlimit" + "\0" + max.to_s + "\0" + skip.to_s) return nil doc/classes/TokyoTyrant/RDBQRY.src/M000056.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1235 + <pre># File tokyotyrant.rb, line 1272 def search() rv = @rdb.misc("search", @args, RDB::MONOULOG) return rv ? rv : Array.new doc/classes/TokyoTyrant/RDBQRY.src/M000057.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1241 + <pre># File tokyotyrant.rb, line 1278 def searchout() args = Array.new(@args) args.push("out") doc/classes/TokyoTyrant/RDBQRY.src/M000058.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1251 + <pre># File tokyotyrant.rb, line 1288 def searchget(names = nil) raise ArgumentError if names && !names.is_a?(Array) args = Array.new(@args) doc/classes/TokyoTyrant/RDBQRY.src/M000059.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1040 + <pre># File tokyotyrant.rb, line 1077 def put(pkey, cols) pkey = _argstr(pkey) raise ArgumentError if !cols.is_a?(Hash) doc/classes/TokyoTyrant/RDBTBL.src/M000001.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1057 + <pre># File tokyotyrant.rb, line 1094 def putkeep(pkey, cols) pkey = _argstr(pkey) raise ArgumentError if !cols.is_a?(Hash) doc/classes/TokyoTyrant/RDBTBL.src/M000002.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1074 + <pre># File tokyotyrant.rb, line 1111 def putcat(pkey, cols) pkey = _argstr(pkey) raise ArgumentError if !cols.is_a?(Hash) doc/classes/TokyoTyrant/RDBTBL.src/M000003.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1089 + <pre># File tokyotyrant.rb, line 1126 def out(pkey) pkey = _argstr(pkey) return super(pkey) doc/classes/TokyoTyrant/RDBTBL.src/M000004.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1096 + <pre># File tokyotyrant.rb, line 1133 def get(pkey) pkey = _argstr(pkey) args = Array.new doc/classes/TokyoTyrant/RDBTBL.src/M000005.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1116 + <pre># File tokyotyrant.rb, line 1153 def mget(recs) rv = super(recs) return -1 if rv < 0 doc/classes/TokyoTyrant/RDBTBL.src/M000006.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1136 + <pre># File tokyotyrant.rb, line 1173 def setindex(name, type) name = _argstr(name) type = _argnum(type) doc/classes/TokyoTyrant/RDBTBL.src/M000007.html @@ -10,7 +10,7 @@ <link rel="stylesheet" href="../../.././rdoc-style.css" type="text/css" media="screen" /> </head> <body class="standalone-code"> - <pre># File tokyotyrant.rb, line 1147 + <pre># File tokyotyrant.rb, line 1184 def genuid() rv = misc("genuid", Array.new, 0) return -1 if !rv doc/classes/TokyoTyrant/RDBTBL.src/M000008.html @@ -1 +1 @@ -Tue, 10 Mar 2009 20:21:48 +0900 +Mon, 30 Mar 2009 22:03:42 +0900 doc/created.rid @@ -56,7 +56,7 @@ </tr> <tr class="top-aligned-row"> <td>Last Update:</td> - <td>Tue Mar 10 20:06:50 +0900 2009</td> + <td>Mon Mar 30 21:58:50 +0900 2009</td> </tr> </table> </div> doc/files/tokyotyrant_rb.html @@ -40,24 +40,24 @@ <a href="classes/TokyoTyrant/RDB.html#M000038">fetch (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDB.html#M000025">fwmkeys (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDBTBL.html#M000008">genuid (TokyoTyrant::RDBTBL)</a> - <a href="classes/TokyoTyrant/RDB.html#M000020">get (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDBTBL.html#M000005">get (TokyoTyrant::RDBTBL)</a> + <a href="classes/TokyoTyrant/RDB.html#M000020">get (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDB.html#M000039">has_key? (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDB.html#M000040">has_value? (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDB.html#M000023">iterinit (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDB.html#M000024">iternext (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDB.html#M000050">keys (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDB.html#M000042">length (TokyoTyrant::RDB)</a> - <a href="classes/TokyoTyrant/RDB.html#M000021">mget (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDBTBL.html#M000006">mget (TokyoTyrant::RDBTBL)</a> + <a href="classes/TokyoTyrant/RDB.html#M000021">mget (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDB.html#M000035">misc (TokyoTyrant::RDB)</a> - <a href="classes/TokyoTyrant/RDBQRY.html#M000052">new (TokyoTyrant::RDBQRY)</a> <a href="classes/TokyoTyrant/RDB.html#M000009">new (TokyoTyrant::RDB)</a> + <a href="classes/TokyoTyrant/RDBQRY.html#M000052">new (TokyoTyrant::RDBQRY)</a> <a href="classes/TokyoTyrant/RDB.html#M000012">open (TokyoTyrant::RDB)</a> - <a href="classes/TokyoTyrant/RDB.html#M000019">out (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDBTBL.html#M000004">out (TokyoTyrant::RDBTBL)</a> - <a href="classes/TokyoTyrant/RDB.html#M000014">put (TokyoTyrant::RDB)</a> + <a href="classes/TokyoTyrant/RDB.html#M000019">out (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDBTBL.html#M000001">put (TokyoTyrant::RDBTBL)</a> + <a href="classes/TokyoTyrant/RDB.html#M000014">put (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDB.html#M000016">putcat (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDBTBL.html#M000003">putcat (TokyoTyrant::RDBTBL)</a> <a href="classes/TokyoTyrant/RDBTBL.html#M000002">putkeep (TokyoTyrant::RDBTBL)</a> @@ -66,6 +66,7 @@ <a href="classes/TokyoTyrant/RDB.html#M000017">putshl (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDB.html#M000032">rnum (TokyoTyrant::RDB)</a> <a href="classes/TokyoTyrant/RDBQRY.html#M000057">search (TokyoTyrant::RDBQRY)</a> + <a href="classes/TokyoTyrant/RDBQRY.html#M000060">searchcount (TokyoTyrant::RDBQRY)</a> <a href="classes/TokyoTyrant/RDBQRY.html#M000059">searchget (TokyoTyrant::RDBQRY)</a> <a href="classes/TokyoTyrant/RDBQRY.html#M000058">searchout (TokyoTyrant::RDBQRY)</a> <a href="classes/TokyoTyrant/RDBTBL.html#M000007">setindex (TokyoTyrant::RDBTBL)</a> doc/fr_method_index.html @@ -863,15 +863,20 @@ def proctable(host, port, rnum) if rand(20) == 0 qry.setlimit(10, rand(10)) res = qry.searchget - res.each do |cols| - pkey = cols[""] - str = cols["str"] + res.each do |rcols| + pkey = rcols[""] + str = rcols["str"] if !pkey || !str || pkey != str eprint(rdb, "searchget") err = true break end end + if(qry.searchcount != res.size) + eprint(rdb, "searchcount") + err = true + break + end onum = rdb.rnum if !qry.searchout eprint(rdb, "searchout") tcrtest.rb @@ -1,5 +1,7 @@ #! /usr/bin/ruby +require 'rbconfig' + commands = [ "tcrtest.rb write 127.0.0.1 10000", @@ -11,9 +13,10 @@ commands = [ "tcrtest.rb rcat -ext put 127.0.0.1 1000", "tcrtest.rb misc 127.0.0.1 1000", ] +rubycmd = Config::CONFIG["bindir"] + "/" + RbConfig::CONFIG['ruby_install_name'] num = 1 commands.each do |command| - rv = system("/usr/bin/ruby #{command} >/dev/null") + rv = system("#{rubycmd} #{command} >/dev/null") if rv printf("%03d/%03d: %s: ok\n", num, commands.size, command) else test.rb @@ -2,7 +2,7 @@ require 'rubygems' spec = Gem::Specification.new do |s| s.name = "tokyotyrant" - s.version = "1.4" + s.version = "1.5" s.author "Mikio Hirabayashi" s.email = "mikio@users.sourceforge.net" s.homepage = "http://tokyocabinet.sourceforge.net/" tokyotyrant.gemspec @@ -57,6 +57,7 @@ module TokyoTyrant # The return value is the new remote database object.%% def initialize() @ecode = ESUCCESS + @enc = nil @sock = nil end # Get the message string corresponding to an error code.%% @@ -115,6 +116,10 @@ module TokyoTyrant @ecode = EREFUSED return false end + begin + sock.setsockopt(Socket::IPPROTO_TCP, Socket::TCP_NODELAY, true) + rescue Exception + end else begin sock = UNIXSocket.open(host) @@ -123,6 +128,9 @@ module TokyoTyrant return false end end + if sock.respond_to?(:set_encoding) + sock.set_encoding("ASCII-8BIT") + end @sock = sock return true end @@ -337,7 +345,7 @@ module TokyoTyrant @ecode = ERECV return nil end - return vbuf + return _retstr(vbuf) end # Retrieve records.%% # `recs' specifies a hash containing the retrieval keys. As a result of this method, keys existing in the database have the corresponding values and keys not existing in the database are removed.%% @@ -388,7 +396,7 @@ module TokyoTyrant @ecode = ERECV return -1 end - recs[kbuf] = vbuf + recs[kbuf] = _retstr(vbuf) end return rnum end @@ -474,7 +482,7 @@ module TokyoTyrant @ecode = ERECV return nil end - return vbuf + return _retstr(vbuf) end # Get forward matching keys.%% # `prefix' specifies the prefix of the corresponding keys.%% @@ -520,7 +528,7 @@ module TokyoTyrant @ecode = ERECV return Array.new end - keys.push(kbuf) + keys.push(_retstr(kbuf)) end return keys end @@ -626,7 +634,7 @@ module TokyoTyrant @ecode = ERECV return nil end - return vbuf + return _retstr(vbuf) end # Synchronize updated contents with the file and the device.%% # If successful, the return value is true, else, it is false.%% @@ -778,7 +786,7 @@ module TokyoTyrant @ecode = ERECV return nil end - return sbuf + return _retstr(sbuf) end # Call a versatile function for miscellaneous operations.%% # `name' specifies the name of the function. All databases support "putlist", "outlist", and "getlist". "putlist" is to store records. It receives keys and values one after the other, and returns an empty list. "outlist" is to remove records. It receives keys, and returns an empty array. "getlist" is to retrieve records. It receives keys, and returns keys and values of corresponding records one after the other. Table database supports "setindex", "search", and "genuid".%% @@ -825,7 +833,7 @@ module TokyoTyrant @ecode = ERECV return nil end - res.push(ebuf) + res.push(_retstr(ebuf)) end return res end @@ -949,15 +957,44 @@ module TokyoTyrant private # Get a string argument.%% def _argstr(obj) - return obj.to_s if obj.is_a?(Numeric) - return obj if obj.is_a?(String) - raise ArgumentError + case obj + when Numeric + obj = obj.to_s + when Symbol + obj = obj.to_s + when String + else + raise ArgumentError + end + if obj.respond_to?(:force_encoding) + obj = obj.dup + obj.force_encoding("ASCII-8BIT") + end + return obj end # Get a numeric argument.%% def _argnum(obj) - return obj.to_i if obj.is_a?(String) - return obj if obj.is_a?(Numeric) - raise ArgumentError + case obj + when String + obj = obj.to_i + when Numeric + else + raise ArgumentError + end + return obj + end + # Get a normalized string to be returned + def _retstr(str) + if str.respond_to?(:force_encoding) + if @enc + str.force_encoding(@enc) + elsif Encoding.default_internal + str.force_encoding(Encoding.default_internal) + else + str.force_encoding("UTF-8") + end + end + return str end # Send a series of data.%% def _send(buf) @@ -1271,6 +1308,14 @@ module TokyoTyrant end return rv end + # Get the count of corresponding records.%% + # The return value is the count of corresponding records or 0 on failure.%% + def searchcount() + args = Array.new(@args) + args.push("count") + rv = @rdb.misc("search", args, RDB::MONOULOG) + return rv ? rv[0].to_i : 0 + end end end tokyotyrant.rb 5882211d4c45844325c7c3e4899e24cf17f2982d Jeremy Hinegardner jeremy@hinegardner.org http://github.com/careo/tokyotyrant-ruby/commit/5523c0cfd25c3b87462329250d984ec16463cb84 5523c0cfd25c3b87462329250d984ec16463cb84

2009-04-20T20:30:40-07:00

2009-04-09T10:51:59-07:00

Update with 1.5 source Signed-off-by: Dane Jensen <careo@fastmail.fm> 3b2b8948dfb90bae5c5cfe3f744ded81a7c8d21e Dane Jensen careo@fastmail.fm