public class PFMongodbAccessor extends java.lang.Object implements PFComponent, PFDataCreateEventSource, PFProcessTerminateEventSource, PFXMLSerializable
コンストラクタと説明 |
---|
PFMongodbAccessor()
コンポーネントを生成する。
|
修飾子とタイプ | メソッドと説明 |
---|---|
void |
addPFDataCreateListener(PFDataCreateListener lis)
引数で与えられたイベントリスナを登録し、
データ生成イベント発生時に処理を行う対象とする。
|
void |
addPFProcessTerminateListener(PFProcessTerminateListener lis)
引数で与えられたイベントリスナを登録し、
処理完了イベント発生時に処理を行う対象とする。
|
void |
closeConnection()
データベース接続を切断する。
|
void |
deleteMany(java.lang.String collection,
PFMongoFilter filter)
コレクション上の複数のドキュメントを削除する。
|
void |
deleteOne(java.lang.String collection,
PFMongoFilter filter)
コレクション上の1件のドキュメントを削除する。
|
PFObjectList |
getCollectionList()
データベースに存在するコレクション名のリストを取得する。
|
int |
getComponentID()
コンポーネントIDを取得する。
|
java.lang.String |
getComponentKey()
コンポーネントキーを取得する。
|
PFMultiLocaleString |
getComponentKeys()
全ロケール分のコンポーネントキーを返す。
|
java.lang.String |
getComponentName()
コンポーネント名称を取得する。
|
java.lang.String |
getComponentPublicName()
コンポーネント公開名を取得する.
|
java.lang.String |
getComponentString()
コンポーネントの文字列表現を取得する。
|
PFObjectTable |
getData(java.lang.String collection,
PFMongoFilter filter,
PFMongoSortCondition sort)
検索条件に該当するドキュメントを最大件数まで検索し、テーブル形式データに変換して取得する。
|
PFObjectTable |
getData(java.lang.String collection,
PFMongoFilter filter,
PFMongoSortCondition sort,
int maxRows)
検索条件に該当するドキュメントを最大件数まで検索し、テーブル形式データに変換して取得する。
|
PFObjectTable |
getDataAsString(java.lang.String collection,
PFMongoFilter filter,
PFMongoSortCondition sort)
検索条件に該当するドキュメントを最大件数まで検索し、テーブル形式データに変換して取得する。
|
PFObjectTable |
getDataAsString(java.lang.String collection,
PFMongoFilter filter,
PFMongoSortCondition sort,
int maxRows)
検索条件に該当するドキュメントを最大件数まで検索し、テーブル形式データに変換して取得する。
|
long |
getDataCount(java.lang.String collection,
PFMongoFilter filter)
検索条件に該当するドキュメント数を取得する。
|
Document |
getDocumentAt(java.lang.String collection,
PFMongoFilter filter,
PFMongoSortCondition sort,
int index)
検索条件に該当する指定した位置のドキュメントを取得する。
|
PFObjectList |
getDocuments(java.lang.String collection,
PFMongoFilter filter,
PFMongoSortCondition sort)
検索条件に該当するドキュメントのリストを最大件数まで取得する。
|
PFObjectList |
getDocuments(java.lang.String collection,
PFMongoFilter filter,
PFMongoSortCondition sort,
int maxCount)
検索条件に該当するドキュメントのリストを最大件数まで取得する。
|
Document |
getFirstDocument(java.lang.String collection,
PFMongoFilter filter,
PFMongoSortCondition sort)
検索条件に該当する最初のドキュメントを取得する。
|
int |
getLimit()
データ取得件数上限値を取得する。
|
java.util.Iterator |
getPFDataCreateListenerList()
データ生成イベントリスナ配列を取得する。
|
java.util.Iterator |
getPFProcessTerminateListenerList()
処理完了イベントリスナ配列を取得する。
|
void |
insertMany(java.lang.String collection,
PFObjectList objList)
コレクションにドキュメントを1件追加する。
|
void |
insertOne(java.lang.String collection,
PFBsonDocumentVariable doc)
コレクションにドキュメントを1件追加する。
|
boolean |
isAllowPullTransfer()
他PFからのPull型コンポーネント転送要求に対する可否属性を取得する.
|
boolean |
isAllowPushTransfer()
他PFへのPush型コンポーネント転送要求に対する可否属性を取得する.
|
boolean |
isAllowRemoteInvocation()
他PFからのコンポーネント連携要求に対する可否属性を取得する.
|
void |
localeUpdated()
ロケール変更に対応する。
|
void |
openConnection(java.lang.String host,
int port,
java.lang.String dbname)
データベースに接続する。
|
void |
openConnection(java.lang.String host,
int port,
java.lang.String dbname,
java.lang.String user,
java.lang.String pass)
データベースに接続する。
|
void |
readXML(PFXMLLoader in)
XMLを入力する.
|
void |
removePFDataCreateListener(PFDataCreateListener lis)
引数で与えられたイベントリスナを削除し、
データ生成イベント発生時に処理を行う対象から外す。
|
void |
removePFProcessTerminateListener(PFProcessTerminateListener lis)
引数で与えられたイベントリスナを削除し、
処理完了イベント発生時に処理を行う対象から外す。
|
void |
setAllowPullTransfer(boolean flag)
他PFからのPull型コンポーネント転送要求に対する可否属性を設定する.
|
void |
setAllowPushTransfer(boolean flag)
他PFへのPush型コンポーネント転送要求に対する可否属性を設定する.
|
void |
setAllowRemoteInvocation(boolean flag)
他PFからのコンポーネント連携要求に対する可否属性を設定する.
|
void |
setComponentID(int id)
コンポーネントIDを設定する。
|
void |
setComponentKey(java.lang.String key)
コンポーネントキーを設定する。
|
void |
setComponentKeys(PFMultiLocaleString keys)
全ロケール分のコンポーネントキーを設定する。
|
void |
setComponentPublicName(java.lang.String publicName)
コンポーネント公開名を設定する.
|
void |
setLimit(int limit)
データ取得件数上限値を設定する。
|
void |
updateMany(java.lang.String collection,
PFMongoFilter filter,
PFBsonDocumentVariable doc,
boolean upsert)
コレクション上の複数のドキュメントを更新する。
|
void |
updateMany(java.lang.String collection,
PFMongoFilter filter,
PFMapVariable values,
boolean upsert)
コレクション上の複数のドキュメントを更新する。
|
void |
updateOne(java.lang.String collection,
PFMongoFilter filter,
PFBsonDocumentVariable doc,
boolean upsert)
コレクション上の1件のドキュメントを更新する。
|
void |
updateOne(java.lang.String collection,
PFMongoFilter filter,
PFMapVariable values,
boolean upsert)
コレクション上の1件のドキュメントを更新する。
|
void |
writeXML(PFXMLGenerator out)
XMLを出力する.
|
public java.lang.String getComponentName()
getComponentName
インタフェース内 PFComponent
public java.lang.String getComponentKey()
getComponentKey
インタフェース内 PFComponent
public void setComponentKey(java.lang.String key)
setComponentKey
インタフェース内 PFComponent
key
- コンポーネントキーpublic PFMultiLocaleString getComponentKeys()
public void setComponentKeys(PFMultiLocaleString keys)
keys
- 全ロケール分のコンポーネントキーpublic int getComponentID()
getComponentID
インタフェース内 PFComponent
public void setComponentID(int id)
PFComponentBus
から設定される。
各コンポーネント内では操作しないこと。setComponentID
インタフェース内 PFComponent
id
- 設定するコンポーネントIDpublic java.lang.String getComponentString()
getComponentString
インタフェース内 PFComponent
public java.lang.String getComponentPublicName()
getComponentPublicName
インタフェース内 PFComponent
public void setComponentPublicName(java.lang.String publicName) throws PFComponentException
setComponentPublicName
インタフェース内 PFComponent
publicName
- 設定するコンポーネント公開名PFComponentException
- 規約に反する名前が設定されようとした場合public boolean isAllowRemoteInvocation()
isAllowRemoteInvocation
インタフェース内 PFComponent
public void setAllowRemoteInvocation(boolean flag)
setAllowRemoteInvocation
インタフェース内 PFComponent
flag
- コンポーネント連携要求に対する可否public boolean isAllowPullTransfer()
isAllowPullTransfer
インタフェース内 PFComponent
public void setAllowPullTransfer(boolean flag)
setAllowPullTransfer
インタフェース内 PFComponent
flag
- Pull型コンポーネント転送要求に対する可否public boolean isAllowPushTransfer()
isAllowPushTransfer
インタフェース内 PFComponent
public void setAllowPushTransfer(boolean flag)
setAllowPushTransfer
インタフェース内 PFComponent
flag
- Push型コンポーネント転送要求に対する可否public java.util.Iterator getPFDataCreateListenerList()
getPFDataCreateListenerList
インタフェース内 PFDataCreateEventSource
public void addPFDataCreateListener(PFDataCreateListener lis)
addPFDataCreateListener
インタフェース内 PFDataCreateEventSource
lis
- 追加対象イベントリスナpublic void removePFDataCreateListener(PFDataCreateListener lis)
removePFDataCreateListener
インタフェース内 PFDataCreateEventSource
lis
- 削除対象イベントリスナpublic java.util.Iterator getPFProcessTerminateListenerList()
getPFProcessTerminateListenerList
インタフェース内 PFProcessTerminateEventSource
public void addPFProcessTerminateListener(PFProcessTerminateListener lis)
addPFProcessTerminateListener
インタフェース内 PFProcessTerminateEventSource
lis
- 追加対象イベントリスナpublic void removePFProcessTerminateListener(PFProcessTerminateListener lis)
removePFProcessTerminateListener
インタフェース内 PFProcessTerminateEventSource
lis
- 削除対象イベントリスナpublic void localeUpdated()
localeUpdated
インタフェース内 PFComponent
public void openConnection(java.lang.String host, int port, java.lang.String dbname)
host
- ホスト名port
- ポート番号dbname
- データベース名public void openConnection(java.lang.String host, int port, java.lang.String dbname, java.lang.String user, java.lang.String pass)
host
- ホスト名port
- ポート番号dbname
- データベース名user
- ユーザー名pass
- パスワードpublic void closeConnection()
public PFObjectList getCollectionList()
public long getDataCount(java.lang.String collection, PFMongoFilter filter)
collection
- 検索するコレクション名filter
- フィルタpublic Document getFirstDocument(java.lang.String collection, PFMongoFilter filter, PFMongoSortCondition sort)
collection
- 検索するコレクション名filter
- フィルタsort
- ソート条件public Document getDocumentAt(java.lang.String collection, PFMongoFilter filter, PFMongoSortCondition sort, int index)
collection
- 検索するコレクション名filter
- フィルタsort
- ソート条件index
- 検索対象の位置public PFObjectList getDocuments(java.lang.String collection, PFMongoFilter filter, PFMongoSortCondition sort)
collection
- 検索するコレクション名filter
- フィルタsort
- ソート条件public PFObjectList getDocuments(java.lang.String collection, PFMongoFilter filter, PFMongoSortCondition sort, int maxCount)
collection
- 検索するコレクション名filter
- フィルタsort
- ソート条件maxCount
- 最大件数public PFObjectTable getData(java.lang.String collection, PFMongoFilter filter, PFMongoSortCondition sort)
collection
- 検索するコレクション名filter
- フィルタsort
- ソート条件public PFObjectTable getData(java.lang.String collection, PFMongoFilter filter, PFMongoSortCondition sort, int maxRows)
collection
- 検索するコレクション名filter
- フィルタsort
- ソート条件maxRows
- 最大件数public PFObjectTable getDataAsString(java.lang.String collection, PFMongoFilter filter, PFMongoSortCondition sort)
collection
- 検索するコレクション名filter
- フィルタsort
- ソート条件public PFObjectTable getDataAsString(java.lang.String collection, PFMongoFilter filter, PFMongoSortCondition sort, int maxRows)
collection
- 検索するコレクション名filter
- フィルタsort
- ソート条件maxRows
- 最大件数public void insertOne(java.lang.String collection, PFBsonDocumentVariable doc)
collection
- 追加するコレクション名doc
- ドキュメントpublic void insertMany(java.lang.String collection, PFObjectList objList) throws PFComponentException
collection
- 追加するコレクション名objList
- ドキュメントオブジェクトのリストPFComponentException
- org.bson.Document型以外の要素が含まれているpublic void updateOne(java.lang.String collection, PFMongoFilter filter, PFBsonDocumentVariable doc, boolean upsert)
collection
- 追加するコレクション名filter
- 対象ドキュメントのフィルタdoc
- 更新内容upsert
- 該当するドキュメントが存在しない場合追加するか否かpublic void updateOne(java.lang.String collection, PFMongoFilter filter, PFMapVariable values, boolean upsert) throws PFException
collection
- 追加するコレクション名filter
- 対象ドキュメントのフィルタvalues
- 更新する要素名と値のマップupsert
- 該当するドキュメントが存在しない場合追加するか否かPFException
- valuesがnullであるpublic void updateMany(java.lang.String collection, PFMongoFilter filter, PFBsonDocumentVariable doc, boolean upsert)
collection
- 追加するコレクション名filter
- 対象ドキュメントのフィルタdoc
- 更新内容upsert
- 該当するドキュメントが存在しない場合追加するか否かpublic void updateMany(java.lang.String collection, PFMongoFilter filter, PFMapVariable values, boolean upsert) throws PFException
collection
- 追加するコレクション名filter
- 対象ドキュメントのフィルタvalues
- 更新する要素名と値のマップupsert
- 該当するドキュメントが存在しない場合追加するか否かPFException
- valuesがnullであるpublic void deleteOne(java.lang.String collection, PFMongoFilter filter)
collection
- 追加するコレクション名filter
- 対象ドキュメントのフィルタpublic void deleteMany(java.lang.String collection, PFMongoFilter filter)
collection
- 追加するコレクション名filter
- 対象ドキュメントのフィルタpublic void setLimit(int limit)
limit
- 取得件数上限値public int getLimit()
public void writeXML(PFXMLGenerator out) throws java.io.IOException
writeXML
インタフェース内 PFXMLSerializable
out
- XML出力ユーティリティjava.io.IOException
public void readXML(PFXMLLoader in)
readXML
インタフェース内 PFXMLSerializable
in
- XML入力ユーティリティ