|
|||||||||
前のクラス 次のクラス | フレームあり フレームなし | ||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |
java.lang.Objectokuyama.imdst.client.OkuyamaClient
public class OkuyamaClient
MasterNodeと通信を行うクライアント
ユーザ開発アプリケーションが利用する想定.
使い方)
// Create Okuyama Client Instance
OkuyamaClient okuyamaClient = new OkuyamaClient();
try {
// --------------
// Connecting MasterNode
okuyamaClient.connect(args[1], port);
// Multi MasterNode
// String[] infos = {"MasterNode01:PortNo","MasterNode02:PortNo","MasterNode03:PortNo"};
// okuyamaClient.setConnectionInfos(infos);
// okuyamaClient.autoConnect();
// --------------
// Set Value
if (okuyamaClient.setValue("datasavekey_001", "savedatavalue_001")) {
System.out.println("setValue - Success");
} else {
System.out.println("setValue - Error");
}
// --------------
// Get Value
String[] getRet = okuyamaClient.getValue("datasavekey_001");
if (getRet[0].equals("true")) {
// Data exists
// Value is displayed
System.out.println(ret[1]);
} else if (getRet[0].equals("false")) {
// Data not found
} else if (getRet[0].equals("error")) {
// Server error
// ErrorMessage is displayed
System.out.println(ret[1]);
}
// --------------
// Set Value & Tag
String[] tags = {"tag1", "tag2"};
if (!okuyamaClient.setValue("datasavekey_001", tags, "savedatavalue_001")) {
System.out.println("setValue - Error");
} else {
System.out.println("setValue - Success");
}
// --------------
// Tag Get
Object[] ret = okuyamaClient.getTagKeys("tag1");
if (ret[0].equals("true")) {
// Data exists
String[] keys = (String[])ret[1];
for (int idx = 0; idx < keys.length; idx++) {
// Key is displayed
System.out.println(keys[idx]);
}
} else if (ret[0].equals("false")) {
// Data not found
} else if (ret[0].equals("error")) {
// Server error
// ErrorMessage is displayed
System.out.println(ret[1]);
}
// --------------
// Remove Data
String[] ret = okuyamaClient.removeValue("datasavekey_001");
if (ret[0].equals("true")) {
// Remove success
// Removed data is displayed
System.out.println(ret[1]);
} else if (ret[0].equals("false")) {
// Data not found
} else if (ret[0].equals("error")) {
// Server error
// ErrorMessage is displayed
System.out.println(ret[1]);
}
// --------------
// Add New Value
String[] retParam = okuyamaClient.setNewValue("NewKey", "value999");
if(retParam[0].equals("false")) {
// Register Error
System.out.println(retParam[1]);
} else {
System.out.println("Register Success");
}
} catch (OkuyamaClientException oce) {
oce.printStackTrace();
} finally {
try {
// --------------
// Close
okuyamaClient.close();
} catch (OkuyamaClientException oce2) {
oce2.printStackTrace();
okuyamaClient = null;
}
}
フィールドの概要 | |
---|---|
protected static java.lang.String |
blankStr
|
protected java.io.BufferedReader |
br
|
protected static java.lang.String |
byteDataKeysSep
|
protected boolean |
compressMode
|
protected static java.lang.String |
connectDefaultEncoding
|
protected static java.lang.String |
connectExitStr
|
protected java.lang.StringBuilder |
getValueServerReqBuf
|
protected int |
initParamConnectionTimeout
|
protected java.lang.String |
initParamEncoding
|
protected java.lang.String[] |
initParamMasterNodes
|
protected int |
initParamOpenTimeout
|
protected int |
initParamPort
|
protected java.lang.String |
initParamServer
|
protected java.util.ArrayList |
masterNodesList
|
protected int |
maxKeySize
|
protected int |
maxValueSize
|
protected java.lang.String |
nowConnectServerInfo
|
protected double |
okuyamaVersionNo
|
protected java.io.PrintWriter |
pw
|
protected int |
saveSize
|
static java.lang.String |
SEARCH_VALUE_TYPE_AND
|
static java.lang.String |
SEARCH_VALUE_TYPE_OR
|
protected static java.lang.String |
sepStr
|
protected java.lang.StringBuilder |
setValueServerReqBuf
|
protected java.net.Socket |
socket
|
protected static java.lang.String |
tagKeySep
|
protected java.lang.String |
transactionCode
|
protected boolean |
useAutoConnect
|
コンストラクタの概要 | |
---|---|
OkuyamaClient()
コンストラクタ |
|
OkuyamaClient(int keyMaxSize)
コンストラクタ |
メソッドの概要 | |
---|---|
void |
autoConnect()
設定されたMasterNodeの接続情報を元に自動的に接続を行う. |
boolean |
clearDictionaryCharacters()
検索用の辞書Indexを全てクリアする. |
void |
close()
MasterNodeとの接続を切断. |
void |
connect(java.lang.String server,
int port)
接続処理. |
void |
connect(java.lang.String server,
int port,
java.lang.String encoding)
接続処理. |
void |
connect(java.lang.String server,
int port,
java.lang.String encoding,
int openTimeout,
int connectionTimeout)
接続処理. |
protected byte[] |
dataDecoding(byte[] datas)
|
protected byte[] |
dataEncoding(byte[] datas)
|
java.lang.Object[] |
decrValue(java.lang.String keyStr,
long value)
MasterNodeへデータの減算を要求する. |
void |
endTransaction()
Transactionを終了する. |
protected byte[] |
execCompress(byte[] bytes)
|
protected byte[] |
execDecompres(byte[] bytes)
|
protected java.lang.Object[] |
getByteData(java.lang.String keyStr)
MasterNodeからKeyでデータを取得する(バイナリ). |
java.lang.Object[] |
getByteValue(java.lang.String keyStr)
MasterNodeからKeyでValueを取得する(バイナリ). |
java.lang.Object[] |
getByteValueVer2(java.lang.String keyStr)
MasterNodeからKeyでValueを取得する(バイナリ). |
java.lang.String[] |
getMultiTagKeys(java.lang.String[] tagList)
MasterNodeからTag値を渡すことで紐付くKey値の配列を取得する 複数のTagを指定することで、一度に関連する値を取得可能 複数のTagに紐付く値はマージされて1つとなる(※複数のTagはAND指定の扱いとなる) AND指定. |
java.lang.String[] |
getMultiTagKeys(java.lang.String[] tagList,
boolean margeType)
MasterNodeからTag値を渡すことで紐付くKey値の配列を取得する 複数のTagを指定することで、一度に関連する値を取得可能 複数のTagに紐付く値はマージされて1つとなる 引数のmargeTypeを指定することで、ANDとORを切り替えることが出来る AND指定. |
java.lang.String[] |
getMultiTagKeys(java.lang.String[] tagList,
boolean margeType,
boolean noExistsData)
MasterNodeからTag値を渡すことで紐付くKey値の配列を取得する 複数のTagを指定することで、一度に関連する値を取得可能 複数のTagに紐付く値はマージされて1つとなる 引数のmargeTypeを指定することで、ANDとORを切り替えることが出来る |
OkuyamaResultSet |
getMultiTagKeysResult(java.lang.String[] tagList)
MasterNodeからTagを複数を指定することで紐付くKeyが取得可能な、OkuyamaResultSetを取得する. |
OkuyamaResultSet |
getMultiTagKeysResult(java.lang.String[] tagList,
boolean margeType)
MasterNodeからTagを複数を指定することで紐付くKeyが取得可能な、OkuyamaResultSetを取得する. |
java.util.Map |
getMultiTagValues(java.lang.String[] tagList)
MasterNodeからTag値を渡すことで紐付くValue値の集合を取得する. |
java.util.Map |
getMultiTagValues(java.lang.String[] tagList,
boolean margeType)
MasterNodeからTag値を渡すことで紐付くValue値の集合を取得する 複数のTagを指定することで、一度に関連する値を取得可能 複数のTagに紐付く値はマージされて1つとなる 引数のmargeTypeを指定することで、ANDとORを切り替えることが出来る 文字列エンコーディング指定なし. |
java.util.Map |
getMultiTagValues(java.lang.String[] tagList,
boolean margeType,
java.lang.String encoding)
MasterNodeからTag値を渡すことで紐付くValue値の集合を取得する 複数のTagを指定することで、一度に関連する値を取得可能 複数のTagに紐付く値はマージされて1つとなる 引数のmargeTypeを指定することで、ANDとORを切り替えることが出来る |
java.util.Map |
getMultiValue(java.lang.String[] keyStrList)
MasterNodeからKey値の配列を渡すことでValue値の集合を取得する. |
java.util.Map |
getMultiValue(java.lang.String[] keyStrList,
java.lang.String encoding)
MasterNodeからKey値の配列を渡すことでValue値の集合を取得する. |
protected java.lang.String |
getNowTransactionCode()
トランザクションを開始している場合、自身のトランザクションを一意に表す コードを返す. |
java.lang.Object[] |
getObjectValue(java.lang.String keyStr)
MasterNodeからKeyでValueを取得する. |
java.lang.Object[] |
getObjectValueAndUpdateExpireTime(java.lang.String keyStr)
MasterNodeからKeyでValueを取得する. |
java.lang.String[] |
getOkuyamaVersion()
クライアントが接続しているokuyamaのバージョン名を返す. |
java.lang.Object[] |
getTagKeys(java.lang.String tagStr)
MasterNodeからTagでKey値配列を取得する. |
java.lang.Object[] |
getTagKeys(java.lang.String tagStr,
boolean noExistsData)
MasterNodeからTagでKey値配列を取得する. |
java.lang.Object[] |
getTagKeys(java.lang.String tagStr,
boolean noExistsData,
boolean decodeKey)
MasterNodeからTagでKey値配列を取得する. |
OkuyamaResultSet |
getTagKeysResult(java.lang.String tagStr)
MasterNodeからTagを指定することで紐付くKeyとValueが取得可能な、OkuyamaResultSetを取得する. |
OkuyamaResultSet |
getTagKeysResult(java.lang.String tagStr,
double[] targetRange,
int cehckType)
MasterNodeからTagを指定することで紐付くKeyとValueが取得可能な、OkuyamaResultSetを取得する. |
OkuyamaResultSet |
getTagKeysResult(java.lang.String tagStr,
double[] targetRange,
int cehckType,
java.lang.String encoding)
MasterNodeからTagを指定することで紐付くKeyとValueが取得可能な、OkuyamaResultSetを取得する. |
OkuyamaResultSet |
getTagKeysResult(java.lang.String tagStr,
java.lang.String encoding)
MasterNodeからTagを指定することで紐付くKeyとValueが取得可能な、OkuyamaResultSetを取得する. |
OkuyamaResultSet |
getTagKeysResult(java.lang.String tagStr,
java.lang.String matchPattern,
int cehckType)
MasterNodeからTagを指定することで紐付くKeyとValueが取得可能な、OkuyamaResultSetを取得する. |
OkuyamaResultSet |
getTagKeysResult(java.lang.String tagStr,
java.lang.String matchPattern,
int cehckType,
java.lang.String encoding)
MasterNodeからTagを指定することで紐付くKeyとValueが取得可能な、OkuyamaResultSetを取得する. |
OkuyamaResultSet |
getTagKeysResult(java.lang.String tagStr,
UserDataFilter filter)
MasterNodeからTagを指定することで紐付くKeyとValueが取得可能な、OkuyamaResultSetを取得する. |
OkuyamaResultSet |
getTagKeysResult(java.lang.String tagStr,
UserDataFilter filter,
java.lang.String encoding)
MasterNodeからTagを指定することで紐付くKeyとValueが取得可能な、OkuyamaResultSetを取得する. |
java.util.Map |
getTagValues(java.lang.String tagStr)
MasterNodeからTag値を渡すことで紐付くValue値の集合を取得する. |
java.util.Map |
getTagValues(java.lang.String tagStr,
java.lang.String encoding)
MasterNodeからTag値を渡すことで紐付くValue値の集合を取得する. |
java.lang.Object[] |
getTargetIndexTagKeys(java.lang.String tagStr,
java.lang.String bucketIndex)
MasterNodeからTagとKey格納bucketのIndexを使用してKey値配列を取得する. |
java.lang.String[] |
getValue(java.lang.String keyStr)
MasterNodeからKeyでValueを取得する. |
java.lang.String[] |
getValue(java.lang.String keyStr,
java.lang.String encoding)
MasterNodeからKeyでValueを取得する. |
java.lang.String[] |
getValueAndUpdateExpireTime(java.lang.String keyStr)
MasterNodeからKeyでValueを取得する. |
java.lang.String[] |
getValueAndUpdateExpireTime(java.lang.String keyStr,
java.lang.String encoding)
MasterNodeからKeyでValueを取得する. |
java.lang.String[] |
getValueScript(java.lang.String keyStr,
java.lang.String scriptStr)
MasterNodeからKeyでValueを取得する. |
java.lang.String[] |
getValueScript(java.lang.String keyStr,
java.lang.String scriptStr,
java.lang.String encoding)
MasterNodeからKeyでデータを取得する. |
java.lang.String[] |
getValueScriptForUpdate(java.lang.String keyStr,
java.lang.String scriptStr)
MasterNodeからKeyでValueを取得する. |
java.lang.String[] |
getValueScriptForUpdate(java.lang.String keyStr,
java.lang.String scriptStr,
java.lang.String encoding)
MasterNodeからKeyでデータを取得する. |
java.lang.String[] |
getValueVersionCheck(java.lang.String keyStr)
MasterNodeからKeyでValueを取得する. |
java.lang.String[] |
getValueVersionCheck(java.lang.String keyStr,
java.lang.String encoding)
MasterNodeからKeyでValueを取得する. |
java.lang.Object[] |
incrValue(java.lang.String keyStr,
long value)
MasterNodeへデータの加算を要求する. |
boolean |
initClient()
Clientを初期化する. |
java.lang.String[] |
lockData(java.lang.String keyStr,
int lockingTime,
int waitLockTime)
データのLockを依頼する. |
java.lang.Object[] |
readByteValue(java.lang.String keyStr)
MasterNodeからKeyでデータを取得する(バイナリ). |
protected java.lang.Object[] |
readSearchValueResponse(java.lang.String[] searchCharacterList,
java.lang.String searchType,
java.lang.String prefix)
MasterNodeからsetValueAndCreateIndexで作成されたIndexを使って検索して該当する値を取得する. |
protected java.lang.Object[] |
readSearchValueResponse(java.lang.String[] searchCharacterList,
java.lang.String searchType,
java.lang.String prefix,
int searchIndexLen)
MasterNodeからsetValueAndCreateIndexで作成されたIndexを使って検索して該当する値を取得する. |
java.lang.String[] |
releaseLockData(java.lang.String keyStr)
データのLock解除を依頼する. |
boolean |
removeSearchIndex(java.lang.String keyStr)
全文検索用のIndexを削除する。 |
boolean |
removeSearchIndex(java.lang.String keyStr,
int indexLength)
全文検索用のIndexを削除する。 |
boolean |
removeSearchIndex(java.lang.String keyStr,
java.lang.String indexPrefix)
全文検索用のIndexを削除する。 |
boolean |
removeSearchIndex(java.lang.String keyStr,
java.lang.String indexPrefix,
int indexLength)
全文検索用のIndexを削除する。 |
boolean |
removeTagFromKey(java.lang.String keyStr,
java.lang.String tagStr)
MasterNodeへKey値とTag値を指定してTagの紐付きを削除する. |
java.lang.String[] |
removeValue(java.lang.String keyStr)
MasterNodeからKeyでValueを削除する. |
java.lang.String[] |
removeValue(java.lang.String keyStr,
java.lang.String encoding)
MasterNodeからKeyでデータを削除する. |
java.lang.Object[] |
searchValue(java.lang.String[] searchCharacterList,
java.lang.String searchType)
MasterNodeからsetValueAndCreateIndexで作成されたIndexを使って検索して該当する値を取得する. |
java.lang.Object[] |
searchValue(java.lang.String[] searchCharacterList,
java.lang.String searchType,
int searchIndexLen)
MasterNodeからsetValueAndCreateIndexで作成されたIndexを使って検索して該当する値を取得する. |
java.lang.Object[] |
searchValue(java.lang.String[] searchCharacterList,
java.lang.String searchType,
java.lang.String prefix)
MasterNodeからsetValueAndCreateIndexで作成されたIndexを使って検索して該当する値を取得する. |
java.lang.Object[] |
searchValue(java.lang.String[] searchCharacterList,
java.lang.String searchType,
java.lang.String prefix,
int searchIndexLen)
MasterNodeからsetValueAndCreateIndexで作成されたIndexを使って検索して該当する値を取得する. |
boolean |
sendByteValue(java.lang.String keyStr,
byte[] values)
MasterNodeへデータを送信する(バイナリデータ). |
protected void |
sendSearchValueRequest(java.lang.String[] searchCharacterList,
java.lang.String searchType)
MasterNodeからsetValueAndCreateIndexで作成されたIndexを使って検索して該当する値を取得する. |
protected void |
sendSearchValueRequest(java.lang.String[] searchCharacterList,
java.lang.String searchType,
int searchIndexLen)
MasterNodeからsetValueAndCreateIndexで作成されたIndexを使って検索して該当する値を取得する. |
protected void |
sendSearchValueRequest(java.lang.String[] searchCharacterList,
java.lang.String searchType,
java.lang.String prefix,
int searchIndexLen)
MasterNodeからsetValueAndCreateIndexで作成されたIndexを使って検索して該当する値を取得する. |
boolean |
setByteValue(java.lang.String keyStr,
byte[] values)
MasterNodeへデータを登録要求する(バイナリデータ). |
boolean |
setByteValue(java.lang.String keyStr,
byte[] values,
java.lang.Integer expireTime)
MasterNodeへデータを登録要求する(バイナリデータ). |
boolean |
setByteValue(java.lang.String keyStr,
java.lang.String[] tagStrs,
byte[] values)
MasterNodeへデータを登録要求する(バイナリデータ). |
boolean |
setByteValue(java.lang.String keyStr,
java.lang.String[] tagStrs,
byte[] values,
java.lang.Integer expireTime)
MasterNodeへデータを登録要求する(バイナリデータ). |
void |
setCompressMode(boolean flg)
データ保存時の圧縮指定. |
void |
setConnectionInfos(java.lang.String[] masterNodes)
MasterNodeの接続情報を設定する. |
boolean |
setDictionaryCharacters(java.lang.String[] characterList)
検索用の辞書Indexを設定する. |
void |
setMethodTimeoutTime(int time)
MasterNodeとのコネクション確立後の処理依頼に対するタイムアウト時間. |
java.lang.String[] |
setNewValue(java.lang.String keyStr,
java.lang.String value)
MasterNodeへ新規データを登録要求する. |
java.lang.String[] |
setNewValue(java.lang.String keyStr,
java.lang.String[] tags,
java.lang.String value)
MasterNodeへ新規データを登録要求する. |
java.lang.String[] |
setNewValue(java.lang.String keyStr,
java.lang.String[] tagStrs,
java.lang.String value,
java.lang.String encode,
java.lang.Integer expireTime)
MasterNodeへ新規データを登録要求する. |
java.lang.String[] |
setNewValue(java.lang.String keyStr,
java.lang.String value,
java.lang.Integer expireTime)
MasterNodeへ新規データを登録要求する. |
java.lang.String[] |
setNewValue(java.lang.String keyStr,
java.lang.String value,
java.lang.String encode)
MasterNodeへ新規データを登録要求する. |
java.lang.String[] |
setNewValue(java.lang.String keyStr,
java.lang.String value,
java.lang.String encode,
java.lang.Integer expireTime)
MasterNodeへ新規データを登録要求する. |
protected void |
setNowTransactionCode(java.lang.String transactionCode)
他のクライアントが実施しているトランザクションコードを設定することで、 トランザクション処理を引き継ぐことが出来る。 |
boolean |
setObjectValue(java.lang.String keyStr,
java.lang.Object objValue)
MasterNodeへデータを送信する(Object). |
boolean |
setObjectValue(java.lang.String keyStr,
java.lang.Object objValue,
java.lang.Integer expireTime)
MasterNodeへデータを送信する(Object). |
boolean |
setObjectValue(java.lang.String keyStr,
java.lang.String[] tagStrs,
java.lang.Object objValue)
MasterNodeへデータを送信する(Object). |
boolean |
setObjectValue(java.lang.String keyStr,
java.lang.String[] tagStrs,
java.lang.Object objValue,
java.lang.Integer expireTime)
MasterNodeへデータを送信する(Object). |
void |
setSendDataDebug(boolean debug)
クライアントがokuyamaに送信しているデータをデバッグする. |
boolean |
setValue(java.lang.String keyStr,
java.lang.String value)
MasterNodeへデータを登録要求する. |
boolean |
setValue(java.lang.String keyStr,
java.lang.String[] tagStrs,
java.lang.String value)
MasterNodeへデータを登録要求する. |
boolean |
setValue(java.lang.String keyStr,
java.lang.String[] tagStrs,
java.lang.String value,
java.lang.Integer expireTime)
MasterNodeへデータを登録要求する. |
boolean |
setValue(java.lang.String keyStr,
java.lang.String[] tagStrs,
java.lang.String value,
java.lang.String encode)
MasterNodeへデータを登録要求する. |
boolean |
setValue(java.lang.String keyStr,
java.lang.String[] tagStrs,
java.lang.String value,
java.lang.String encode,
java.lang.Integer expireTime)
MasterNodeへデータを登録要求する. |
boolean |
setValue(java.lang.String keyStr,
java.lang.String value,
java.lang.Integer expireTime)
MasterNodeへデータを登録要求する. |
boolean |
setValue(java.lang.String keyStr,
java.lang.String value,
java.lang.String encode)
MasterNodeへデータを登録要求する. |
boolean |
setValue(java.lang.String keyStr,
java.lang.String value,
java.lang.String encode,
java.lang.Integer expireTime)
MasterNodeへデータを登録要求する. |
boolean |
setValueAndCreateIndex(java.lang.String keyStr,
java.lang.String value)
MasterNodeへデータを登録要求する. |
boolean |
setValueAndCreateIndex(java.lang.String keyStr,
java.lang.String[] tagStrs,
java.lang.String value,
java.lang.String indexPrefix)
MasterNodeへデータを登録要求する. |
boolean |
setValueAndCreateIndex(java.lang.String keyStr,
java.lang.String[] tagStrs,
java.lang.String value,
java.lang.String indexPrefix,
int createIndexLen)
MasterNodeへデータを登録要求する. |
boolean |
setValueAndCreateIndex(java.lang.String keyStr,
java.lang.String[] tagStrs,
java.lang.String value,
java.lang.String indexPrefix,
int createIndexLen,
int createIndexLenMin)
MasterNodeへデータを登録要求する. |
boolean |
setValueAndCreateIndex(java.lang.String keyStr,
java.lang.String value,
java.lang.String indexPrefix)
MasterNodeへデータを登録要求する. |
boolean |
setValueAndCreateIndex(java.lang.String keyStr,
java.lang.String value,
java.lang.String indexPrefix,
int createIndexLen)
MasterNodeへデータを登録要求する. |
boolean |
setValueAndCreateIndex(java.lang.String keyStr,
java.lang.String value,
java.lang.String indexPrefix,
int createIndexLen,
int createIndexLenMin)
MasterNodeへデータを登録要求する. |
java.lang.String[] |
setValueVersionCheck(java.lang.String keyStr,
java.lang.String[] tagStrs,
java.lang.String value,
java.lang.String versionNo)
MasterNodeへバージョンチェック付き値登録要求をする. |
java.lang.String[] |
setValueVersionCheck(java.lang.String keyStr,
java.lang.String[] tagStrs,
java.lang.String value,
java.lang.String versionNo,
java.lang.String encode)
MasterNodeへバージョンチェック付き値登録要求をする. |
java.lang.String[] |
setValueVersionCheck(java.lang.String keyStr,
java.lang.String value,
java.lang.String versionNo)
MasterNodeへバージョンチェック付き値登録要求をする. |
boolean |
startTransaction()
Transactionを開始する. |
クラス java.lang.Object から継承されたメソッド |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
フィールドの詳細 |
---|
protected java.util.ArrayList masterNodesList
protected java.net.Socket socket
protected java.lang.String nowConnectServerInfo
protected double okuyamaVersionNo
protected boolean useAutoConnect
protected java.lang.String[] initParamMasterNodes
protected java.lang.String initParamServer
protected int initParamPort
protected java.lang.String initParamEncoding
protected int initParamOpenTimeout
protected int initParamConnectionTimeout
protected java.io.PrintWriter pw
protected java.io.BufferedReader br
protected java.lang.String transactionCode
public static final java.lang.String SEARCH_VALUE_TYPE_AND
public static final java.lang.String SEARCH_VALUE_TYPE_OR
protected static final java.lang.String sepStr
protected static final java.lang.String connectDefaultEncoding
protected static final java.lang.String blankStr
protected static final java.lang.String connectExitStr
protected static final java.lang.String tagKeySep
protected static final java.lang.String byteDataKeysSep
protected int saveSize
protected int maxValueSize
protected int maxKeySize
protected boolean compressMode
protected java.lang.StringBuilder setValueServerReqBuf
protected java.lang.StringBuilder getValueServerReqBuf
コンストラクタの詳細 |
---|
public OkuyamaClient()
public OkuyamaClient(int keyMaxSize)
メソッドの詳細 |
---|
public void setCompressMode(boolean flg)
flg
- true:圧縮 false:非圧縮public void setMethodTimeoutTime(int time)
time
- タイムアウト時間(単位はミリ秒)public void setConnectionInfos(java.lang.String[] masterNodes)
masterNodes
- 接続情報の配列 "IP:PORT"の形式public void autoConnect() throws OkuyamaClientException
masterNodes
- 接続情報の配列 "IP:PORT"の形式
OkuyamaClientException
public void connect(java.lang.String server, int port) throws OkuyamaClientException
server
- サーバ名port
- ポート番号
OkuyamaClientException
public void connect(java.lang.String server, int port, java.lang.String encoding) throws OkuyamaClientException
server
- サーバ名port
- ポート番号
OkuyamaClientException
public void connect(java.lang.String server, int port, java.lang.String encoding, int openTimeout, int connectionTimeout) throws OkuyamaClientException
server
- サーバ名port
- ポート番号encoding
- サーバとのストリームエンコーディング指定(デフォルトUTF-8)
OkuyamaClientException
public void close() throws OkuyamaClientException
OkuyamaClientException
public void setSendDataDebug(boolean debug)
debug
- 指定public boolean initClient() throws OkuyamaClientException
OkuyamaClientException
public java.lang.String[] getOkuyamaVersion() throws OkuyamaClientException
OkuyamaClientException
public boolean startTransaction() throws OkuyamaClientException
OkuyamaClientException
public void endTransaction()
public java.lang.String[] lockData(java.lang.String keyStr, int lockingTime, int waitLockTime) throws OkuyamaClientException
keyStr
- ロック対象のKey値lockingTime
- Lockを取得後、維持する時間(この時間を経過すると自動的にLockが解除される)(単位は秒)(0は無制限)waitLockTime
- Lockを取得する場合に既に取得中の場合この時間はLock取得をリトライする(単位は秒)(0は1度取得を試みる)
OkuyamaClientException
public java.lang.String[] releaseLockData(java.lang.String keyStr) throws OkuyamaClientException
keyStr
- ロック対象Key値
OkuyamaClientException
protected java.lang.String getNowTransactionCode()
protected void setNowTransactionCode(java.lang.String transactionCode)
public boolean setValue(java.lang.String keyStr, java.lang.String value) throws OkuyamaClientException
keyStr
- Key値value
- value値
OkuyamaClientException
public boolean setValue(java.lang.String keyStr, java.lang.String value, java.lang.Integer expireTime) throws OkuyamaClientException
keyStr
- Key値value
- value値expireTime
- データの有効期限時間(単位/秒)
OkuyamaClientException
public boolean setValue(java.lang.String keyStr, java.lang.String value, java.lang.String encode) throws OkuyamaClientException
keyStr
- Key値value
- value値encode
- Valueを取得後クライアントに返す際の文字コード
OkuyamaClientException
public boolean setValue(java.lang.String keyStr, java.lang.String value, java.lang.String encode, java.lang.Integer expireTime) throws OkuyamaClientException
keyStr
- Key値value
- value値encode
- Valueを取得後クライアントに返す際の文字コードexpireTime
- データの有効期限時間(単位/秒)
OkuyamaClientException
public boolean setValue(java.lang.String keyStr, java.lang.String[] tagStrs, java.lang.String value) throws OkuyamaClientException
keyStr
- Key値tagStrs
- Tag値の配列 例){"tag1","tag2","tag3"}value
- value値
OkuyamaClientException
public boolean setValue(java.lang.String keyStr, java.lang.String[] tagStrs, java.lang.String value, java.lang.Integer expireTime) throws OkuyamaClientException
keyStr
- Key値tagStrs
- Tag値の配列 例){"tag1","tag2","tag3"}value
- value値expireTime
- データの有効期限時間(単位/秒)
OkuyamaClientException
public boolean setValue(java.lang.String keyStr, java.lang.String[] tagStrs, java.lang.String value, java.lang.String encode) throws OkuyamaClientException
keyStr
- Key値tagStrs
- Tag値の配列 例){"tag1","tag2","tag3"}value
- value値
OkuyamaClientException
public boolean setValue(java.lang.String keyStr, java.lang.String[] tagStrs, java.lang.String value, java.lang.String encode, java.lang.Integer expireTime) throws OkuyamaClientException
keyStr
- Key値tagStrs
- Tag値の配列 例){"tag1","tag2","tag3"}value
- value値encode
- Valueを取得後クライアントに返す際の文字コードexpireTime
- データの有効期限時間(単位/秒)
OkuyamaClientException
public boolean setValueAndCreateIndex(java.lang.String keyStr, java.lang.String value) throws OkuyamaClientException
keyStr
- Key値value
- value値
OkuyamaClientException
public boolean setValueAndCreateIndex(java.lang.String keyStr, java.lang.String value, java.lang.String indexPrefix) throws OkuyamaClientException
keyStr
- Key値value
- value値indexPrefix
- 作成する検索IndexをグルーピングするPrefix文字列.この値と同様の値を指定してsearchValueメソッドを呼び出すと、グループに限定して全文検索が可能となる. 最大は128文字
OkuyamaClientException
public boolean setValueAndCreateIndex(java.lang.String keyStr, java.lang.String value, java.lang.String indexPrefix, int createIndexLen) throws OkuyamaClientException
keyStr
- Key値value
- value値indexPrefix
- 作成する検索IndexをグルーピングするPrefix文字列.この値と同様の値を指定してsearchValueメソッドを呼び出すと、グループに限定して全文検索が可能となる. 最大は128文字createIndexLen
- 作成するN-GramIndxのNの部分は指定(ヒストグラム以上のIndexを作成可能)
OkuyamaClientException
public boolean setValueAndCreateIndex(java.lang.String keyStr, java.lang.String value, java.lang.String indexPrefix, int createIndexLen, int createIndexLenMin) throws OkuyamaClientException
keyStr
- Key値value
- value値indexPrefix
- 作成する検索IndexをグルーピングするPrefix文字列.この値と同様の値を指定してsearchValueメソッドを呼び出すと、グループに限定して全文検索が可能となる. 最大は128文字createIndexLen
- 作成するN-GramIndxのNの部分は指定(ヒストグラム以上のIndexを作成可能)createIndexLenMin
- 作成するN-GramIndxの最小のNを指定する。例えば3を指定すると2文字までのIndexは作成しない
OkuyamaClientException
public boolean setValueAndCreateIndex(java.lang.String keyStr, java.lang.String[] tagStrs, java.lang.String value, java.lang.String indexPrefix) throws OkuyamaClientException
keyStr
- Key値tagStrs
- Tag値の配列 例){"tag1","tag2","tag3"}value
- value値indexPrefix
- 作成する検索IndexをグルーピングするPrefix文字列.この値と同様の値を指定してsearchValueメソッドを呼び出すと、グループに限定して全文検索が可能となる. 最大は128文字createIndexLen
- 作成するN-GramIndxのNの部分は指定(ヒストグラム以上のIndexを作成可能)
OkuyamaClientException
public boolean setValueAndCreateIndex(java.lang.String keyStr, java.lang.String[] tagStrs, java.lang.String value, java.lang.String indexPrefix, int createIndexLen) throws OkuyamaClientException
keyStr
- Key値tagStrs
- Tag値の配列 例){"tag1","tag2","tag3"}value
- value値indexPrefix
- 作成する検索IndexをグルーピングするPrefix文字列.この値と同様の値を指定してsearchValueメソッドを呼び出すと、グループに限定して全文検索が可能となる. 最大は128文字createIndexLen
- 作成するN-GramIndxのNの部分は指定(ヒストグラム以上のIndexを作成可能)
OkuyamaClientException
public boolean setValueAndCreateIndex(java.lang.String keyStr, java.lang.String[] tagStrs, java.lang.String value, java.lang.String indexPrefix, int createIndexLen, int createIndexLenMin) throws OkuyamaClientException
keyStr
- Key値tagStrs
- Tag値の配列 例){"tag1","tag2","tag3"}value
- value値indexPrefix
- 作成する検索IndexをグルーピングするPrefix文字列.この値と同様の値を指定してsearchValueメソッドを呼び出すと、グループに限定して全文検索が可能となる. 最大は128文字createIndexLen
- 作成するN-GramIndxのNの部分は指定(ヒストグラム以上のIndexを作成可能)createIndexLenMin
- 作成するN-GramIndxの最小のNを指定する。例えば3を指定すると2文字までのIndexは作成しない
OkuyamaClientException
public boolean setDictionaryCharacters(java.lang.String[] characterList) throws OkuyamaClientException
dictionaryStrList
-
OkuyamaClientException
public boolean clearDictionaryCharacters() throws OkuyamaClientException
dictionaryStrList
-
OkuyamaClientException
public java.lang.String[] setNewValue(java.lang.String keyStr, java.lang.String value) throws OkuyamaClientException
keyStr
- Key値value
- Value値
OkuyamaClientException
public java.lang.String[] setNewValue(java.lang.String keyStr, java.lang.String[] tags, java.lang.String value) throws OkuyamaClientException
keyStr
- Key値tagStrs
- Tag値 例){"tag1","tag2","tag3"}value
- Value値
OkuyamaClientException
public java.lang.String[] setNewValue(java.lang.String keyStr, java.lang.String value, java.lang.Integer expireTime) throws OkuyamaClientException
keyStr
- Key値value
- Value値expireTime
- 有効期限(秒/単位)
OkuyamaClientException
public java.lang.String[] setNewValue(java.lang.String keyStr, java.lang.String value, java.lang.String encode) throws OkuyamaClientException
keyStr
- Key値value
- Value値encode
- Encode指定
OkuyamaClientException
public java.lang.String[] setNewValue(java.lang.String keyStr, java.lang.String value, java.lang.String encode, java.lang.Integer expireTime) throws OkuyamaClientException
keyStr
- Key値value
- Value値encode
- Encode指定expireTime
- 有効期限(秒/単位)
OkuyamaClientException
public java.lang.String[] setNewValue(java.lang.String keyStr, java.lang.String[] tagStrs, java.lang.String value, java.lang.String encode, java.lang.Integer expireTime) throws OkuyamaClientException
keyStr
- Key値tagStrs
- Tag値 例){"tag1","tag2","tag3"}value
- Value値encode
- Encode指定expireTime
- 有効期限(秒/単位)
OkuyamaClientException
public java.lang.String[] setValueVersionCheck(java.lang.String keyStr, java.lang.String value, java.lang.String versionNo) throws OkuyamaClientException
keyStr
- Key値value
- Value値versionNo
- getValueVersionCheckメソッドで取得したバージョンNo
OkuyamaClientException
public java.lang.String[] setValueVersionCheck(java.lang.String keyStr, java.lang.String[] tagStrs, java.lang.String value, java.lang.String versionNo) throws OkuyamaClientException
keyStr
- Key値tagStrs
- Tag値value
- Value値versionNo
- getValueVersionCheckメソッドで取得したバージョンNo
OkuyamaClientException
public java.lang.String[] setValueVersionCheck(java.lang.String keyStr, java.lang.String[] tagStrs, java.lang.String value, java.lang.String versionNo, java.lang.String encode) throws OkuyamaClientException
keyStr
- Key値tagStrs
- Tag値value
- Value値versionNo
- getValueVersionCheckメソッドで取得したバージョンNoencode
- エンコード
OkuyamaClientException
public boolean setByteValue(java.lang.String keyStr, byte[] values) throws OkuyamaClientException
keyStr
- Key値values
- Value値(byte配列)
OkuyamaClientException
public boolean setByteValue(java.lang.String keyStr, byte[] values, java.lang.Integer expireTime) throws OkuyamaClientException
keyStr
- Key値values
- Value値(byte配列)expireTime
- 有効期限(単位は秒)
OkuyamaClientException
public boolean setByteValue(java.lang.String keyStr, java.lang.String[] tagStrs, byte[] values) throws OkuyamaClientException
keyStr
- Key値tagStrs
- Tag値values
- Value値(byte配列)
OkuyamaClientException
public boolean setByteValue(java.lang.String keyStr, java.lang.String[] tagStrs, byte[] values, java.lang.Integer expireTime) throws OkuyamaClientException
keyStr
- Key値tagStrs
- Tag値values
- Value値(byte配列)expireTime
- 有効期限(単位は秒)
OkuyamaClientException
public boolean sendByteValue(java.lang.String keyStr, byte[] values) throws OkuyamaClientException
keyStr
- Key値values
- Value値
OkuyamaClientException
public boolean setObjectValue(java.lang.String keyStr, java.lang.Object objValue) throws OkuyamaClientException
keyStr
- Key値objValues
- Value値
OkuyamaClientException
public boolean setObjectValue(java.lang.String keyStr, java.lang.String[] tagStrs, java.lang.Object objValue) throws OkuyamaClientException
keyStr
- Key値tagStrs
- Tag値の配列 例){"tag1","tag2","tag3"}objValues
- Value値
OkuyamaClientException
public boolean setObjectValue(java.lang.String keyStr, java.lang.Object objValue, java.lang.Integer expireTime) throws OkuyamaClientException
keyStr
- Key値objValues
- Value値expireTime
- 有効期限(単位は秒)
OkuyamaClientException
public boolean setObjectValue(java.lang.String keyStr, java.lang.String[] tagStrs, java.lang.Object objValue, java.lang.Integer expireTime) throws OkuyamaClientException
keyStr
- Key値tagStrs
- Tag値の配列 例){"tag1","tag2","tag3"}objValues
- Value値expireTime
- 有効期限(単位は秒)
OkuyamaClientException
public java.lang.String[] getValue(java.lang.String keyStr) throws OkuyamaClientException
keyStr
- Key値
OkuyamaClientException
public java.lang.String[] getValue(java.lang.String keyStr, java.lang.String encoding) throws OkuyamaClientException
keyStr
- Key値encoding
- エンコーディング指定
OkuyamaClientException
public java.lang.Object[] getObjectValue(java.lang.String keyStr) throws OkuyamaClientException
keyStr
- Key値
OkuyamaClientException
public java.lang.Object[] getObjectValueAndUpdateExpireTime(java.lang.String keyStr) throws OkuyamaClientException
keyStr
- Key値
OkuyamaClientException
public java.util.Map getMultiValue(java.lang.String[] keyStrList) throws OkuyamaClientException
keyStrList
- Key値配列OkuyamaClientException
public java.util.Map getMultiValue(java.lang.String[] keyStrList, java.lang.String encoding) throws OkuyamaClientException
keyStrList
- Key値配列encoding
- エンコーディング指定
OkuyamaClientException
public java.lang.String[] getValueAndUpdateExpireTime(java.lang.String keyStr) throws OkuyamaClientException
keyStr
- Key値
OkuyamaClientException
public java.lang.String[] getValueAndUpdateExpireTime(java.lang.String keyStr, java.lang.String encoding) throws OkuyamaClientException
keyStr
- Key値encoding
- エンコーディング指定
OkuyamaClientException
public java.util.Map getTagValues(java.lang.String tagStr) throws OkuyamaClientException
tagStr
- Tag値
OkuyamaClientException
public java.util.Map getTagValues(java.lang.String tagStr, java.lang.String encoding) throws OkuyamaClientException
tagStr
- Tag値encoding
- エンコーディング指定
OkuyamaClientException
public java.lang.String[] getMultiTagKeys(java.lang.String[] tagList) throws OkuyamaClientException
tagList
- Tag値のリスト
OkuyamaClientException
public java.lang.String[] getMultiTagKeys(java.lang.String[] tagList, boolean margeType) throws OkuyamaClientException
tagList
- Tag値のリストmargeType
- 取得方法指定(true = AND、false=OR)
OkuyamaClientException
public java.lang.String[] getMultiTagKeys(java.lang.String[] tagList, boolean margeType, boolean noExistsData) throws OkuyamaClientException
tagList
- Tag値のリストmargeType
- 取得方法指定(true = AND、false=OR)noExistsData
- 存在していないデータを取得するかの指定(true:取得する false:取得しない)
OkuyamaClientException
public java.util.Map getMultiTagValues(java.lang.String[] tagList) throws OkuyamaClientException
tagList
- Tag値のリスト
OkuyamaClientException
public java.util.Map getMultiTagValues(java.lang.String[] tagList, boolean margeType) throws OkuyamaClientException
tagList
- Tag値のリストmargeType
- 取得方法指定(true = AND、false=OR)
OkuyamaClientException
public java.util.Map getMultiTagValues(java.lang.String[] tagList, boolean margeType, java.lang.String encoding) throws OkuyamaClientException
tagList
- Tag値のリストmargeType
- 取得方法指定(true = AND、false=OR)encoding
- エンコーディング指定
OkuyamaClientException
public java.lang.String[] getValueVersionCheck(java.lang.String keyStr) throws OkuyamaClientException
keyStr
- Key値
OkuyamaClientException
public java.lang.String[] getValueVersionCheck(java.lang.String keyStr, java.lang.String encoding) throws OkuyamaClientException
keyStr
- Key値encoding
-
OkuyamaClientException
public java.lang.Object[] incrValue(java.lang.String keyStr, long value) throws OkuyamaClientException
keyStr
- Key値value
- 加算値
OkuyamaClientException
public java.lang.Object[] decrValue(java.lang.String keyStr, long value) throws OkuyamaClientException
keyStr
- Key値value
- 減算値
OkuyamaClientException
public java.lang.String[] getValueScript(java.lang.String keyStr, java.lang.String scriptStr) throws OkuyamaClientException
keyStr
- キー値scriptStr
- スクリプト文
OkuyamaClientException
public java.lang.String[] getValueScript(java.lang.String keyStr, java.lang.String scriptStr, java.lang.String encoding) throws OkuyamaClientException
keyStr
- キー値scriptStr
- スクリプト文encoding
- エンコード指定
OkuyamaClientException
public java.lang.String[] getValueScriptForUpdate(java.lang.String keyStr, java.lang.String scriptStr) throws OkuyamaClientException
keyStr
- キー値scriptStr
- スクリプト文
OkuyamaClientException
public java.lang.String[] getValueScriptForUpdate(java.lang.String keyStr, java.lang.String scriptStr, java.lang.String encoding) throws OkuyamaClientException
keyStr
- キー値scriptStr
- スクリプト文encoding
-
OkuyamaClientException
public java.lang.String[] removeValue(java.lang.String keyStr) throws OkuyamaClientException
keyStr
- Key値
OkuyamaClientException
public java.lang.String[] removeValue(java.lang.String keyStr, java.lang.String encoding) throws OkuyamaClientException
keyStr
- Key値
OkuyamaClientException
public boolean removeTagFromKey(java.lang.String keyStr, java.lang.String tagStr) throws OkuyamaClientException
keyStr
- Key値tagStr
- tag値
OkuyamaClientException
public boolean removeSearchIndex(java.lang.String keyStr) throws OkuyamaClientException
keyStr
- Key値
OkuyamaClientException
public boolean removeSearchIndex(java.lang.String keyStr, java.lang.String indexPrefix) throws OkuyamaClientException
keyStr
- Key値indexPrefix
- 作成時に設定したIndexのPrefix値
OkuyamaClientException
public boolean removeSearchIndex(java.lang.String keyStr, int indexLength) throws OkuyamaClientException
keyStr
- Key値indexLength
- 作成時に指定した作成Indexの長さ指定
OkuyamaClientException
public boolean removeSearchIndex(java.lang.String keyStr, java.lang.String indexPrefix, int indexLength) throws OkuyamaClientException
keyStr
- Key値indexPrefix
- 作成時に設定したIndexのPrefix値indexLength
- 作成時に指定した作成Indexの長さ指定
OkuyamaClientException
public java.lang.Object[] getByteValue(java.lang.String keyStr) throws OkuyamaClientException
keyStr
- Key値
OkuyamaClientException
public java.lang.Object[] getByteValueVer2(java.lang.String keyStr) throws OkuyamaClientException
keyStr
- Key値
OkuyamaClientException
protected java.lang.Object[] getByteData(java.lang.String keyStr) throws OkuyamaClientException
keyStr
- Key値
OkuyamaClientException
public java.lang.Object[] readByteValue(java.lang.String keyStr) throws OkuyamaClientException
keyStr
- Key値
OkuyamaClientException
public java.lang.Object[] getTagKeys(java.lang.String tagStr) throws OkuyamaClientException
tagStr
- Tag値
OkuyamaClientException
public java.lang.Object[] getTagKeys(java.lang.String tagStr, boolean noExistsData) throws OkuyamaClientException
tagStr
- Tag値noExistsData
- 存在していないデータを取得するかの指定(true:取得する false:取得しない)
OkuyamaClientException
public java.lang.Object[] getTagKeys(java.lang.String tagStr, boolean noExistsData, boolean decodeKey) throws OkuyamaClientException
tagStr
- Tag値noExistsData
- 存在していないデータを取得するかの指定(true:取得する false:取得しない)decodeKey
- 取得するKey値をBase64デコードして返す指定
OkuyamaClientException
public OkuyamaResultSet getTagKeysResult(java.lang.String tagStr) throws OkuyamaClientException
tagStr
- Tag値
OkuyamaClientException
public OkuyamaResultSet getTagKeysResult(java.lang.String tagStr, java.lang.String encoding) throws OkuyamaClientException
tagStr
- Tag値encoding
- エンコーディング指定
OkuyamaClientException
public OkuyamaResultSet getTagKeysResult(java.lang.String tagStr, java.lang.String matchPattern, int cehckType) throws OkuyamaClientException
tagStr
- Tag値matchPattern
- 正規表現文字列(Java標準の記法) 取得するKey、Valueのどちらかもしくは両方がここで指定する正規表現パターンとマッチする場合のみOkuyamaResultSetから取得できるcehckType
- 正規表現パターンをマッチする先を指定 1=Key, 2=Value, 3=両方
OkuyamaClientException
public OkuyamaResultSet getTagKeysResult(java.lang.String tagStr, java.lang.String matchPattern, int cehckType, java.lang.String encoding) throws OkuyamaClientException
tagStr
- Tag値matchPattern
- 正規表現文字列(Java標準の記法) 取得するKey、Valueのどちらかもしくは両方がここで指定する正規表現パターンとマッチする場合のみOkuyamaResultSetから取得できるcehckType
- 正規表現パターンをマッチする先を指定 1=Key, 2=Value, 3=両方encoding
- Valueを復元する際に利用するエンコーディング指定
OkuyamaClientException
public OkuyamaResultSet getTagKeysResult(java.lang.String tagStr, double[] targetRange, int cehckType) throws OkuyamaClientException
tagStr
- Tag値targetRange
- 取得するKey、Valueのどちらかもしくは両方がここで指定する値の範囲内の場合のみOkuyamaResultSetから取得できるcehckType
- 範囲条件を指定する先を指定 1=Key, 2=Value, 3=両方
OkuyamaClientException
public OkuyamaResultSet getTagKeysResult(java.lang.String tagStr, double[] targetRange, int cehckType, java.lang.String encoding) throws OkuyamaClientException
tagStr
- Tag値targetRange
- 取得するKey、Valueのどちらかもしくは両方がここで指定する値の範囲内の場合のみOkuyamaResultSetから取得できるcehckType
- 範囲条件を指定する先を指定 1=Key, 2=Value, 3=両方encoding
- Valueを復元する際に利用するエンコーディング指定
OkuyamaClientException
public OkuyamaResultSet getTagKeysResult(java.lang.String tagStr, UserDataFilter filter) throws OkuyamaClientException
tagStr
- Tag値filter
- 独自実装によるフィルターインスタンス
OkuyamaClientException
public OkuyamaResultSet getTagKeysResult(java.lang.String tagStr, UserDataFilter filter, java.lang.String encoding) throws OkuyamaClientException
tagStr
- Tag値filter
- 独自実装によるフィルターインスタンスencoding
- Valueを復元する際に利用するエンコーディング指定
OkuyamaClientException
public OkuyamaResultSet getMultiTagKeysResult(java.lang.String[] tagList) throws OkuyamaClientException
tagList
- Tag値の配列
OkuyamaClientException
public OkuyamaResultSet getMultiTagKeysResult(java.lang.String[] tagList, boolean margeType) throws OkuyamaClientException
tagList
- Tag値の配列margeType
- 取得方法指定(true = AND、false=OR)
OkuyamaClientException
public java.lang.Object[] getTargetIndexTagKeys(java.lang.String tagStr, java.lang.String bucketIndex) throws OkuyamaClientException
tagStr
- Tag値index
- bucketIndex
OkuyamaClientException
public java.lang.Object[] searchValue(java.lang.String[] searchCharacterList, java.lang.String searchType) throws OkuyamaClientException
searchCharacterList
- 取得したい値の文字配列(エンコードはUTF-8固定)searchType
- "1":AND検索 "2":OR検索
OkuyamaClientException
public java.lang.Object[] searchValue(java.lang.String[] searchCharacterList, java.lang.String searchType, int searchIndexLen) throws OkuyamaClientException
searchCharacterList
- 取得したい値の文字配列(エンコードはUTF-8固定)searchType
- 1:AND検索 2:OR検索searchIndexLen
- 検索するIndexをヒストグラムIndex以上にする場合にそのIndexの長さを指定
OkuyamaClientException
public java.lang.Object[] searchValue(java.lang.String[] searchCharacterList, java.lang.String searchType, java.lang.String prefix) throws OkuyamaClientException
searchCharacterList
- 取得したい値の文字配列(エンコードはUTF-8固定)searchType
- 1:AND検索 2:OR検索prefix
- 検索Index作成時に指定したPrefix値
OkuyamaClientException
public java.lang.Object[] searchValue(java.lang.String[] searchCharacterList, java.lang.String searchType, java.lang.String prefix, int searchIndexLen) throws OkuyamaClientException
searchCharacterList
- 取得したい値の文字配列(エンコードはUTF-8固定)searchType
- 1:AND検索 2:OR検索prefix
- 検索Index作成時に指定したPrefix値searchIndexLen
- 検索するIndexをヒストグラムIndex以上にする場合にそのIndexの長さを指定
OkuyamaClientException
protected void sendSearchValueRequest(java.lang.String[] searchCharacterList, java.lang.String searchType) throws OkuyamaClientException
searchCharacterList
- 取得したい値の文字配列(エンコードはUTF-8固定)searchType
- 1:AND検索 2:OR検索
OkuyamaClientException
protected void sendSearchValueRequest(java.lang.String[] searchCharacterList, java.lang.String searchType, int searchIndexLen) throws OkuyamaClientException
searchCharacterList
- 取得したい値の文字配列(エンコードはUTF-8固定)searchType
- 1:AND検索 2:OR検索searchIndexLen
- 検索するIndexをヒストグラムIndex以上にする場合にそのIndexの長さを指定
OkuyamaClientException
protected void sendSearchValueRequest(java.lang.String[] searchCharacterList, java.lang.String searchType, java.lang.String prefix, int searchIndexLen) throws OkuyamaClientException
searchCharacterList
- 取得したい値の文字配列(エンコードはUTF-8固定)searchType
- 1:AND検索 2:OR検索prefix
- 検索Index作成時に指定したPrefix値searchIndexLen
- 検索するIndexをヒストグラムIndex以上にする場合にそのIndexの長さを指定
OkuyamaClientException
protected java.lang.Object[] readSearchValueResponse(java.lang.String[] searchCharacterList, java.lang.String searchType, java.lang.String prefix) throws OkuyamaClientException
searchCharacterList
- 取得したい値の文字配列(エンコードはUTF-8固定)searchType
- 1:AND検索 2:OR検索prefix
- 検索Index作成時に指定したPrefix値
OkuyamaClientException
protected java.lang.Object[] readSearchValueResponse(java.lang.String[] searchCharacterList, java.lang.String searchType, java.lang.String prefix, int searchIndexLen) throws OkuyamaClientException
searchCharacterList
- 取得したい値の文字配列(エンコードはUTF-8固定)searchType
- 1:AND検索 2:OR検索prefix
- 検索Index作成時に指定したPrefix値searchIndexLen
- 検索するIndexをヒストグラムIndex以上にする場合にそのIndexの長さを指定
OkuyamaClientException
protected byte[] dataEncoding(byte[] datas)
protected byte[] dataDecoding(byte[] datas)
protected byte[] execCompress(byte[] bytes) throws java.lang.Exception
java.lang.Exception
protected byte[] execDecompres(byte[] bytes) throws java.lang.Exception
java.lang.Exception
|
|||||||||
前のクラス 次のクラス | フレームあり フレームなし | ||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |