public class DbEnv
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
DbEnv.RepProcessMessage |
Modifier and Type | Field and Description |
---|---|
protected boolean |
swigCMemOwn |
Environment |
wrapper |
Modifier | Constructor and Description |
---|---|
|
DbEnv(int flags) |
protected |
DbEnv(long cPtr,
boolean cMemoryOwn) |
Modifier and Type | Method and Description |
---|---|
DbTxn |
cdsgroup_begin() |
void |
close(int flags) |
void |
dbremove(DbTxn txnid,
java.lang.String file,
java.lang.String database,
int flags) |
void |
dbrename(DbTxn txnid,
java.lang.String file,
java.lang.String database,
java.lang.String newname,
int flags) |
void |
err(int error,
java.lang.String message) |
void |
errx(java.lang.String message) |
void |
fileid_reset(java.lang.String file,
int flags) |
LogRecordHandler |
get_app_dispatch() |
long |
get_cache_max() |
int |
get_cachesize_ncache() |
long |
get_cachesize() |
java.lang.String |
get_create_dir() |
java.lang.String[] |
get_data_dirs() |
int |
get_encrypt_flags() |
ErrorHandler |
get_errcall() |
java.io.OutputStream |
get_error_stream() |
java.lang.String |
get_errpfx() |
EventHandler |
get_event_notify() |
FeedbackHandler |
get_feedback() |
int |
get_flags() |
java.lang.String |
get_home() |
java.lang.String |
get_intermediate_dir_mode() |
int |
get_lg_bsize() |
java.lang.String |
get_lg_dir() |
int |
get_lg_filemode() |
int |
get_lg_max() |
int |
get_lg_regionmax() |
byte[][] |
get_lk_conflicts() |
int |
get_lk_detect() |
int |
get_lk_max_lockers() |
int |
get_lk_max_locks() |
int |
get_lk_max_objects() |
int |
get_lk_partitions() |
java.io.OutputStream |
get_message_stream() |
int |
get_mp_max_openfd() |
long |
get_mp_max_write_sleep() |
int |
get_mp_max_write() |
long |
get_mp_mmapsize() |
int |
get_mp_pagesize() |
int |
get_mp_tablesize() |
MessageHandler |
get_msgcall() |
int |
get_open_flags() |
PanicHandler |
get_paniccall() |
long |
get_shm_key() |
long |
get_timeout(int flag) |
java.lang.String |
get_tmp_dir() |
int |
get_tx_max() |
long |
get_tx_timestamp() |
boolean |
get_verbose(int which) |
static int |
get_version_major() |
static int |
get_version_minor() |
static int |
get_version_patch() |
static java.lang.String |
get_version_string() |
protected static long |
getCPtr(DbEnv obj) |
boolean |
is_bigendian() |
int |
lock_detect(int flags,
int atype) |
DbLock |
lock_get(int locker,
int flags,
DatabaseEntry object,
int lock_mode) |
void |
lock_id_free(int id) |
int |
lock_id() |
void |
lock_put(DbLock lock) |
LockStats |
lock_stat(int flags) |
void |
lock_vec(int locker,
int flags,
LockRequest[] list,
int offset,
int count) |
java.lang.String[] |
log_archive(int flags) |
static int |
log_compare(LogSequenceNumber lsn0,
LogSequenceNumber lsn1) |
DbLogc |
log_cursor(int flags) |
java.lang.String |
log_file(LogSequenceNumber lsn) |
void |
log_flush(LogSequenceNumber lsn_or_null) |
boolean |
log_get_config(int which) |
void |
log_print(DbTxn txn,
java.lang.String msg) |
void |
log_put(LogSequenceNumber lsn,
DatabaseEntry data,
int flags) |
void |
log_set_config(int which,
boolean onoff) |
LogStats |
log_stat(int flags) |
void |
lsn_reset(java.lang.String file,
int flags) |
CacheFileStats[] |
memp_fstat(int flags) |
CacheStats |
memp_stat(int flags) |
void |
memp_sync(LogSequenceNumber lsn) |
int |
memp_trickle(int percent) |
int |
mutex_get_align() |
int |
mutex_get_increment() |
int |
mutex_get_max() |
int |
mutex_get_tas_spins() |
void |
mutex_set_align(int align) |
void |
mutex_set_increment(int increment) |
void |
mutex_set_max(int mutex_max) |
void |
mutex_set_tas_spins(int tas_spins) |
MutexStats |
mutex_stat(int flags) |
void |
open(java.lang.String db_home,
int flags,
int mode) |
void |
remove(java.lang.String db_home,
int flags) |
void |
rep_elect(int nsites,
int nvotes,
int flags) |
void |
rep_flush() |
int |
rep_get_clockskew_fast() |
int |
rep_get_clockskew_slow() |
boolean |
rep_get_config(int which) |
long |
rep_get_limit() |
int |
rep_get_nsites() |
int |
rep_get_priority() |
int |
rep_get_request_max() |
int |
rep_get_request_min() |
int |
rep_get_timeout(int which) |
int |
rep_process_message(DatabaseEntry control,
DatabaseEntry rec,
int envid,
LogSequenceNumber ret_lsn) |
void |
rep_set_clockskew(int fast_clock,
int slow_clock) |
void |
rep_set_config(int which,
boolean onoff) |
void |
rep_set_limit(long bytes) |
void |
rep_set_nsites(int number) |
void |
rep_set_priority(int priority) |
void |
rep_set_request(int min,
int max) |
void |
rep_set_timeout(int which,
long timeout) |
void |
rep_set_transport(int envid,
ReplicationTransport send) |
void |
rep_start(DatabaseEntry cdata,
int flags) |
ReplicationStats |
rep_stat(int flags) |
void |
rep_sync(int flags) |
int |
repmgr_add_remote_site(java.lang.String host,
int port,
int flags) |
void |
repmgr_get_ack_policy() |
void |
repmgr_set_ack_policy(int policy) |
void |
repmgr_set_local_site(java.lang.String host,
int port,
int flags) |
ReplicationManagerSiteInfo[] |
repmgr_site_list() |
void |
repmgr_start(int nthreads,
int flags) |
ReplicationManagerStats |
repmgr_stat(int flags) |
void |
set_app_dispatch(LogRecordHandler tx_recover) |
void |
set_cache_max(long bytes) |
void |
set_cachesize(long bytes,
int ncache) |
void |
set_create_dir(java.lang.String dir) |
void |
set_data_dir(java.lang.String dir) |
void |
set_encrypt(java.lang.String passwd,
int flags) |
void |
set_errcall(ErrorHandler db_errcall_fcn) |
void |
set_error_stream(java.io.OutputStream stream) |
void |
set_errpfx(java.lang.String errpfx) |
void |
set_event_notify(EventHandler event_notify) |
void |
set_feedback(FeedbackHandler env_feedback_fcn) |
void |
set_flags(int flags,
boolean onoff) |
void |
set_intermediate_dir_mode(java.lang.String mode) |
void |
set_lg_bsize(int lg_bsize) |
void |
set_lg_dir(java.lang.String dir) |
void |
set_lg_filemode(int mode) |
void |
set_lg_max(int lg_max) |
void |
set_lg_regionmax(int lg_regionmax) |
void |
set_lk_conflicts(byte[][] conflicts) |
void |
set_lk_detect(int detect) |
void |
set_lk_max_lockers(int max) |
void |
set_lk_max_locks(int max) |
void |
set_lk_max_objects(int max) |
void |
set_lk_partitions(int partitions) |
void |
set_message_stream(java.io.OutputStream stream) |
void |
set_mp_max_openfd(int maxopenfd) |
void |
set_mp_max_write(int maxwrite,
long maxwrite_sleep) |
void |
set_mp_mmapsize(long mp_mmapsize) |
void |
set_mp_pagesize(long mp_pagesize) |
void |
set_mp_tablesize(long mp_tablesize) |
void |
set_msgcall(MessageHandler db_msgcall_fcn) |
void |
set_paniccall(PanicHandler db_panic_fcn) |
void |
set_rpc_server(java.lang.String host,
long cl_timeout,
long sv_timeout,
int flags) |
void |
set_shm_key(long shm_key) |
void |
set_timeout(long timeout,
int flags) |
void |
set_tmp_dir(java.lang.String dir) |
void |
set_tx_max(int max) |
void |
set_tx_timestamp(java.util.Date timestamp) |
void |
set_verbose(int which,
boolean onoff) |
static java.lang.String |
strerror(int error) |
DbTxn |
txn_begin(DbTxn parent,
int flags) |
void |
txn_checkpoint(int kbyte,
int min,
int flags) |
PreparedTransaction[] |
txn_recover(int count,
int flags) |
TransactionStats |
txn_stat(int flags) |
protected boolean swigCMemOwn
public Environment wrapper
protected DbEnv(long cPtr, boolean cMemoryOwn)
public DbEnv(int flags) throws DatabaseException
DatabaseException
protected static long getCPtr(DbEnv obj)
public void close(int flags) throws DatabaseException
DatabaseException
public LogRecordHandler get_app_dispatch() throws DatabaseException
DatabaseException
public EventHandler get_event_notify() throws DatabaseException
DatabaseException
public FeedbackHandler get_feedback() throws DatabaseException
DatabaseException
public void set_errpfx(java.lang.String errpfx)
public java.lang.String get_errpfx()
public ErrorHandler get_errcall()
public MessageHandler get_msgcall()
public PanicHandler get_paniccall() throws DatabaseException
DatabaseException
public void lock_vec(int locker, int flags, LockRequest[] list, int offset, int count) throws DatabaseException
DatabaseException
public void remove(java.lang.String db_home, int flags) throws DatabaseException, java.io.FileNotFoundException
DatabaseException
java.io.FileNotFoundException
public void set_error_stream(java.io.OutputStream stream)
public java.io.OutputStream get_error_stream()
public void set_message_stream(java.io.OutputStream stream)
public java.io.OutputStream get_message_stream()
public void set_tx_timestamp(java.util.Date timestamp) throws DatabaseException
DatabaseException
public void dbremove(DbTxn txnid, java.lang.String file, java.lang.String database, int flags) throws DatabaseException, java.io.FileNotFoundException
DatabaseException
java.io.FileNotFoundException
public void dbrename(DbTxn txnid, java.lang.String file, java.lang.String database, java.lang.String newname, int flags) throws DatabaseException, java.io.FileNotFoundException
DatabaseException
java.io.FileNotFoundException
public void err(int error, java.lang.String message)
public void errx(java.lang.String message)
public DbTxn cdsgroup_begin() throws DatabaseException
DatabaseException
public void fileid_reset(java.lang.String file, int flags) throws DatabaseException
DatabaseException
public java.lang.String[] get_data_dirs() throws DatabaseException
DatabaseException
public int get_encrypt_flags() throws DatabaseException
DatabaseException
public int get_flags() throws DatabaseException
DatabaseException
public java.lang.String get_home() throws DatabaseException
DatabaseException
public java.lang.String get_intermediate_dir_mode() throws DatabaseException
DatabaseException
public int get_open_flags() throws DatabaseException
DatabaseException
public long get_shm_key() throws DatabaseException
DatabaseException
public java.lang.String get_tmp_dir() throws DatabaseException
DatabaseException
public boolean get_verbose(int which) throws DatabaseException
DatabaseException
public boolean is_bigendian() throws DatabaseException
DatabaseException
public void lsn_reset(java.lang.String file, int flags) throws DatabaseException
DatabaseException
public void open(java.lang.String db_home, int flags, int mode) throws DatabaseException, java.io.FileNotFoundException
DatabaseException
java.io.FileNotFoundException
public void set_cachesize(long bytes, int ncache) throws DatabaseException
DatabaseException
public void set_cache_max(long bytes) throws DatabaseException
DatabaseException
public void set_create_dir(java.lang.String dir) throws DatabaseException
DatabaseException
public void set_data_dir(java.lang.String dir) throws DatabaseException
DatabaseException
public void set_intermediate_dir_mode(java.lang.String mode) throws DatabaseException
DatabaseException
public void set_encrypt(java.lang.String passwd, int flags) throws DatabaseException
DatabaseException
public void set_errcall(ErrorHandler db_errcall_fcn)
public void set_flags(int flags, boolean onoff) throws DatabaseException
DatabaseException
public void set_feedback(FeedbackHandler env_feedback_fcn) throws DatabaseException
DatabaseException
public void set_mp_max_openfd(int maxopenfd) throws DatabaseException
DatabaseException
public void set_mp_max_write(int maxwrite, long maxwrite_sleep) throws DatabaseException
DatabaseException
public void set_mp_mmapsize(long mp_mmapsize) throws DatabaseException
DatabaseException
public void set_mp_pagesize(long mp_pagesize) throws DatabaseException
DatabaseException
public void set_mp_tablesize(long mp_tablesize) throws DatabaseException
DatabaseException
public void set_msgcall(MessageHandler db_msgcall_fcn)
public void set_paniccall(PanicHandler db_panic_fcn) throws DatabaseException
DatabaseException
public void set_rpc_server(java.lang.String host, long cl_timeout, long sv_timeout, int flags) throws DatabaseException
DatabaseException
public void set_shm_key(long shm_key) throws DatabaseException
DatabaseException
public void set_timeout(long timeout, int flags) throws DatabaseException
DatabaseException
public void set_tmp_dir(java.lang.String dir) throws DatabaseException
DatabaseException
public void set_tx_max(int max) throws DatabaseException
DatabaseException
public void set_app_dispatch(LogRecordHandler tx_recover) throws DatabaseException
DatabaseException
public void set_event_notify(EventHandler event_notify) throws DatabaseException
DatabaseException
public void set_verbose(int which, boolean onoff) throws DatabaseException
DatabaseException
public byte[][] get_lk_conflicts() throws DatabaseException
DatabaseException
public int get_lk_detect() throws DatabaseException
DatabaseException
public int get_lk_max_locks() throws DatabaseException
DatabaseException
public int get_lk_max_lockers() throws DatabaseException
DatabaseException
public int get_lk_max_objects() throws DatabaseException
DatabaseException
public int get_lk_partitions() throws DatabaseException
DatabaseException
public int lock_detect(int flags, int atype) throws DatabaseException
DatabaseException
public DbLock lock_get(int locker, int flags, DatabaseEntry object, int lock_mode) throws DatabaseException
DatabaseException
public int lock_id() throws DatabaseException
DatabaseException
public void lock_id_free(int id) throws DatabaseException
DatabaseException
public void lock_put(DbLock lock) throws DatabaseException
DatabaseException
public LockStats lock_stat(int flags) throws DatabaseException
DatabaseException
public void set_lk_conflicts(byte[][] conflicts) throws DatabaseException
DatabaseException
public void set_lk_detect(int detect) throws DatabaseException
DatabaseException
public void set_lk_max_lockers(int max) throws DatabaseException
DatabaseException
public void set_lk_max_locks(int max) throws DatabaseException
DatabaseException
public void set_lk_max_objects(int max) throws DatabaseException
DatabaseException
public void set_lk_partitions(int partitions) throws DatabaseException
DatabaseException
public int get_lg_bsize() throws DatabaseException
DatabaseException
public java.lang.String get_lg_dir() throws DatabaseException
DatabaseException
public int get_lg_filemode() throws DatabaseException
DatabaseException
public int get_lg_max() throws DatabaseException
DatabaseException
public int get_lg_regionmax() throws DatabaseException
DatabaseException
public java.lang.String[] log_archive(int flags) throws DatabaseException
DatabaseException
public static int log_compare(LogSequenceNumber lsn0, LogSequenceNumber lsn1)
public DbLogc log_cursor(int flags) throws DatabaseException
DatabaseException
public java.lang.String log_file(LogSequenceNumber lsn) throws DatabaseException
DatabaseException
public void log_flush(LogSequenceNumber lsn_or_null) throws DatabaseException
DatabaseException
public boolean log_get_config(int which) throws DatabaseException
DatabaseException
public void log_put(LogSequenceNumber lsn, DatabaseEntry data, int flags) throws DatabaseException
DatabaseException
public void log_print(DbTxn txn, java.lang.String msg) throws DatabaseException
DatabaseException
public void log_set_config(int which, boolean onoff) throws DatabaseException
DatabaseException
public LogStats log_stat(int flags) throws DatabaseException
DatabaseException
public void set_lg_bsize(int lg_bsize) throws DatabaseException
DatabaseException
public void set_lg_dir(java.lang.String dir) throws DatabaseException
DatabaseException
public void set_lg_filemode(int mode) throws DatabaseException
DatabaseException
public void set_lg_max(int lg_max) throws DatabaseException
DatabaseException
public void set_lg_regionmax(int lg_regionmax) throws DatabaseException
DatabaseException
public long get_cachesize() throws DatabaseException
DatabaseException
public int get_cachesize_ncache() throws DatabaseException
DatabaseException
public long get_cache_max() throws DatabaseException
DatabaseException
public java.lang.String get_create_dir() throws DatabaseException
DatabaseException
public int get_mp_max_openfd() throws DatabaseException
DatabaseException
public int get_mp_max_write() throws DatabaseException
DatabaseException
public long get_mp_max_write_sleep() throws DatabaseException
DatabaseException
public long get_mp_mmapsize() throws DatabaseException
DatabaseException
public int get_mp_pagesize() throws DatabaseException
DatabaseException
public int get_mp_tablesize() throws DatabaseException
DatabaseException
public CacheStats memp_stat(int flags) throws DatabaseException
DatabaseException
public CacheFileStats[] memp_fstat(int flags) throws DatabaseException
DatabaseException
public void memp_sync(LogSequenceNumber lsn) throws DatabaseException
DatabaseException
public int memp_trickle(int percent) throws DatabaseException
DatabaseException
public int mutex_get_align() throws DatabaseException
DatabaseException
public int mutex_get_increment() throws DatabaseException
DatabaseException
public int mutex_get_max() throws DatabaseException
DatabaseException
public int mutex_get_tas_spins() throws DatabaseException
DatabaseException
public void mutex_set_align(int align) throws DatabaseException
DatabaseException
public void mutex_set_increment(int increment) throws DatabaseException
DatabaseException
public void mutex_set_max(int mutex_max) throws DatabaseException
DatabaseException
public void mutex_set_tas_spins(int tas_spins) throws DatabaseException
DatabaseException
public MutexStats mutex_stat(int flags) throws DatabaseException
DatabaseException
public int get_tx_max() throws DatabaseException
DatabaseException
public long get_tx_timestamp() throws DatabaseException
DatabaseException
public long get_timeout(int flag) throws DatabaseException
DatabaseException
public DbTxn txn_begin(DbTxn parent, int flags) throws DatabaseException
DatabaseException
public void txn_checkpoint(int kbyte, int min, int flags) throws DatabaseException
DatabaseException
public PreparedTransaction[] txn_recover(int count, int flags) throws DatabaseException
DatabaseException
public TransactionStats txn_stat(int flags) throws DatabaseException
DatabaseException
public long rep_get_limit() throws DatabaseException
DatabaseException
public void rep_elect(int nsites, int nvotes, int flags) throws DatabaseException
DatabaseException
public int rep_process_message(DatabaseEntry control, DatabaseEntry rec, int envid, LogSequenceNumber ret_lsn)
public void rep_flush() throws DatabaseException
DatabaseException
public void rep_set_config(int which, boolean onoff) throws DatabaseException
DatabaseException
public void rep_set_clockskew(int fast_clock, int slow_clock) throws DatabaseException
DatabaseException
public int rep_get_clockskew_fast() throws DatabaseException
DatabaseException
public int rep_get_clockskew_slow() throws DatabaseException
DatabaseException
public void rep_start(DatabaseEntry cdata, int flags) throws DatabaseException
DatabaseException
public void rep_sync(int flags) throws DatabaseException
DatabaseException
public boolean rep_get_config(int which) throws DatabaseException
DatabaseException
public ReplicationStats rep_stat(int flags) throws DatabaseException
DatabaseException
public void rep_set_limit(long bytes) throws DatabaseException
DatabaseException
public int rep_get_request_min() throws DatabaseException
DatabaseException
public int rep_get_request_max() throws DatabaseException
DatabaseException
public void rep_set_request(int min, int max) throws DatabaseException
DatabaseException
public void rep_set_transport(int envid, ReplicationTransport send) throws DatabaseException
DatabaseException
public int rep_get_nsites() throws DatabaseException
DatabaseException
public int rep_get_priority() throws DatabaseException
DatabaseException
public int rep_get_timeout(int which) throws DatabaseException
DatabaseException
public void rep_set_nsites(int number) throws DatabaseException
DatabaseException
public void rep_set_priority(int priority) throws DatabaseException
DatabaseException
public void rep_set_timeout(int which, long timeout) throws DatabaseException
DatabaseException
public int repmgr_add_remote_site(java.lang.String host, int port, int flags) throws DatabaseException
DatabaseException
public void repmgr_get_ack_policy() throws DatabaseException
DatabaseException
public void repmgr_set_ack_policy(int policy) throws DatabaseException
DatabaseException
public void repmgr_set_local_site(java.lang.String host, int port, int flags) throws DatabaseException
DatabaseException
public ReplicationManagerSiteInfo[] repmgr_site_list() throws DatabaseException
DatabaseException
public void repmgr_start(int nthreads, int flags) throws DatabaseException
DatabaseException
public ReplicationManagerStats repmgr_stat(int flags) throws DatabaseException
DatabaseException
public static java.lang.String strerror(int error)
public static int get_version_major()
public static int get_version_minor()
public static int get_version_patch()
public static java.lang.String get_version_string()