jp.ac.tokushima_u.db.logistics

Class ExtRDB.ExtRDBTable

java.lang.Object

jp.ac.tokushima_u.db.logistics.ExtRDB.ExtRDBTable

All Implemented Interfaces:

ExtRDBCluster.TableInf

Enclosing class:

ExtRDB

public static class ExtRDB.ExtRDBTable
extends Object
implements ExtRDBCluster.TableInf

Field Summary

Fields

Modifier and Type	Field and Description
(package private) AtomicLong	cnt_updates
(package private) int	RETRYs

Constructor Summary

Constructors

Constructor and Description
ExtRDBTable(PgRDB.Table ta, PgRDB.Column... columns) Create table instance.
ExtRDBTable(String name, PgRDB.Column... columns) Create table instance.

Method Summary

Modifier and Type	Method and Description
boolean	create(ExtRDBCluster<ExtRDB> cluster, boolean renew) Create table if table is not exist.
String	createIndex(boolean unique, PgRDB.Column... cols) Create index.
String	createIndex(PgRDB.Column col, boolean unique) Create index.
void	delete(PgRDB.Where delete) Delete rows where specified condition.
void	deleteAndInsert(long retr, PgRDB.Where delete, Collection<PgRDB.Value> values) Delete rows and multiple and insert multiple rows.
void	deleteAndMultipleInsert(long retr, PgRDB.Where delete, Collection<? extends Collection<PgRDB.Value>> valuess) Delete rows and multiple and insert multiple rows.
void	flush() Flush buffered rows.
String	getName() Get name of table.
PgRDB.Table	getTable() get table.
int	idling() Execute idling jobs.
void	setAnalyzeLimit(long l)
void	setRegisters(int n)
void	setReplicaIdentity(String indexName) Set replica identity for PostgreSQL replication.
void	setSQLBufferScale(double s)
void	sweep(long before) Sweep old rows.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

RETRYs

int RETRYs

cnt_updates

AtomicLong cnt_updates

Constructor Detail

ExtRDBTable

public ExtRDBTable(PgRDB.Table ta,
                   PgRDB.Column... columns)

Create table instance.

Parameters:

ta - Table of PgRDB.

columns - columns belong to table.

ExtRDBTable

public ExtRDBTable(String name,
                   PgRDB.Column... columns)

Create table instance.

Parameters:

name - Name of table.

columns - columns belong to table.

Method Detail

getTable

public PgRDB.Table getTable()

get table.

Returns:

Table of PgRDB.

getName

public String getName()

Get name of table.

Specified by:

getName in interface ExtRDBCluster.TableInf

Returns:

name of table.

create

public boolean create(ExtRDBCluster<ExtRDB> cluster,
                      boolean renew)

Create table if table is not exist.

Parameters:

cluster - database.

renew - force create table even if table is already exist.

Returns:

table creation was executed.

createIndex

public String createIndex(PgRDB.Column col,
                          boolean unique)

Create index.

Parameters:

col - Columns for Index

unique - Uniqueness

Returns:

name of index.

createIndex

public String createIndex(boolean unique,
                          PgRDB.Column... cols)

Create index.

Parameters:

unique - Uniqueness

cols - Columns for Index

Returns:

name of index.

setReplicaIdentity

public void setReplicaIdentity(String indexName)

Set replica identity for PostgreSQL replication.

Parameters:

indexName - Name of Index.

deleteAndInsert

public void deleteAndInsert(long retr,
                            PgRDB.Where delete,
                            Collection<PgRDB.Value> values)

Delete rows and multiple and insert multiple rows.

Parameters:

retr - timestamp of data (epoch milliseconds)

delete - Where phrase for deletion.

values - insert value.

deleteAndMultipleInsert

public void deleteAndMultipleInsert(long retr,
                                    PgRDB.Where delete,
                                    Collection<? extends Collection<PgRDB.Value>> valuess)

Delete rows and multiple and insert multiple rows.

Parameters:

retr - timestamp of data (epoch milliseconds)

delete - Where phrase for deletion.

valuess - insert values.

delete

public void delete(PgRDB.Where delete)

Delete rows where specified condition.

Parameters:

delete - Where phrase.

setSQLBufferScale

public void setSQLBufferScale(double s)

setAnalyzeLimit

public void setAnalyzeLimit(long l)

setRegisters

public void setRegisters(int n)

idling

public int idling()

Execute idling jobs.

Specified by:

idling in interface ExtRDBCluster.TableInf

Returns:

Number of extra idling jobs.

flush

public void flush()

Flush buffered rows.

Specified by:

flush in interface ExtRDBCluster.TableInf

sweep

public void sweep(long before)

Sweep old rows.

Specified by:

sweep in interface ExtRDBCluster.TableInf

Parameters:

before - epoch time (milliseconds).