com.xxdb

类 BatchTable

java.lang.Object

java.lang.Thread

com.xxdb.BatchTable

所有已实现的接口:

Runnable

public class BatchTable
extends Thread

嵌套类概要

从类继承的嵌套类/接口 java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

字段概要

字段

限定符和类型	字段和说明
static BasicTable	db 数据表对象
LinkedBlockingQueue<Object[]>	linkedBlockingQueue 任务队列

从类继承的字段 java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

构造器概要

构造器

构造器和说明
BatchTable(DBConnection conn, String databaseName, String tableName)
BatchTable(DBConnection c, String databaseName, String tableName, int batchSize)

方法概要

限定符和类型	方法和说明
int	getBatchSize()
List<String>	getColNames()
List<String>	getColNames(BasicTable db)
List<Vector>	getCols(int size)
List<String>	getColTypes()
List<String>	getColTypes(BasicTable db)
String	getDatabaseName()
Scalar	getScalar(String type, Object object)
Scalar	getScalar(String type, Object object, Object next)
String	getTableName()
void	init()
void	insert(Object... objects)
void	run()
void	setBatchSize(int batchSize)
void	setDatabaseName(String databaseName)
void	setTableName(String tableName)

从类继承的方法 java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

从类继承的方法 java.lang.Object

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

字段详细资料

linkedBlockingQueue

public LinkedBlockingQueue<Object[]> linkedBlockingQueue

任务队列

db

public static BasicTable db

数据表对象

构造器详细资料

BatchTable

public BatchTable(DBConnection conn,
                  String databaseName,
                  String tableName)

BatchTable

public BatchTable(DBConnection c,
                  String databaseName,
                  String tableName,
                  int batchSize)

方法详细资料

init

public void init()

run

public void run()

指定者:

run 在接口中 Runnable

覆盖:

run 在类中 Thread

insert

public void insert(Object... objects)

getCols

public List<Vector> getCols(int size)

getScalar

public Scalar getScalar(String type,
                        Object object)

getScalar

public Scalar getScalar(String type,
                        Object object,
                        Object next)

getColNames

public List<String> getColNames(BasicTable db)

getColNames

public List<String> getColNames()

getColTypes

public List<String> getColTypes(BasicTable db)

getColTypes

public List<String> getColTypes()

getDatabaseName

public String getDatabaseName()

setDatabaseName

public void setDatabaseName(String databaseName)

getTableName

public String getTableName()

setTableName

public void setTableName(String tableName)

getBatchSize

public int getBatchSize()

setBatchSize

public void setBatchSize(int batchSize)