Skip navigation links
com.sigmadynamics.server.DataServices.DatabaseProvider
Class TableWithPuts
java.lang.Object
com.sigmadynamics.server.DataServices.DatabaseProvider.DatabaseTable
com.sigmadynamics.server.DataServices.DatabaseProvider.TableWithPuts
- All Implemented Interfaces:
- BatchUpdaterClient
-
public abstract class TableWithPuts
- extends DatabaseTable
Constructor Summary |
TableWithPuts(DatabaseProviderInterface dataSource, java.lang.String tableName, java.lang.String[] columns, int batchSize, int maxQueueLength, boolean autoFlush, boolean autoGrowBuffer)
|
Method Summary |
void |
close()
|
void |
flush()
|
boolean |
isThrottling()
|
void |
put(int column, byte[] value)
|
void |
put(int column, double value)
|
void |
put(int column, java.io.InputStream value, int length)
|
void |
put(int column, long value)
|
void |
put(int column, java.lang.String value)
|
void |
putDate(int column, long value)
|
void |
putDate(int column, long value, java.util.Calendar cal)
|
void |
putNull(int column, int sqlType)
|
void |
setThrottling(boolean throttling)
|
Methods inherited from class com.sigmadynamics.server.DataServices.DatabaseProvider.DatabaseTable |
getDeadlockHandler, getName, getOperationName, getProvider, getQualifiedName, getSql, getSQLStatement, initializeFromRefreshedCache, prepareStatement, rebuildSql, reportRetries, setSqlString, translateColumnNames |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
bu
protected final BatchUpdater bu
originalColumnNames
protected final java.lang.String[] originalColumnNames
TableWithPuts
TableWithPuts(DatabaseProviderInterface dataSource,
java.lang.String tableName,
java.lang.String[] columns,
int batchSize,
int maxQueueLength,
boolean autoFlush,
boolean autoGrowBuffer)
put
public void put(int column,
java.lang.String value)
put
public void put(int column,
double value)
put
public void put(int column,
long value)
putDate
public void putDate(int column,
long value)
putDate
public void putDate(int column,
long value,
java.util.Calendar cal)
put
public void put(int column,
java.io.InputStream value,
int length)
put
public void put(int column,
byte[] value)
putNull
public void putNull(int column,
int sqlType)
flush
public void flush()
close
public void close()
isThrottling
public boolean isThrottling()
setThrottling
public void setThrottling(boolean throttling)
Skip navigation links
Copyright © 2010, 2011, Oracle. All rights reserved.