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

Field Summary

protected BatchUpdater	bu
protected java.lang.String[]	originalColumnNames

Fields inherited from class com.sigmadynamics.server.DataServices.DatabaseProvider.DatabaseTable

database, log, sqlString, tableCacheEntry, tableName

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

Field Detail

bu

protected final BatchUpdater bu

originalColumnNames

protected final java.lang.String[] originalColumnNames

Constructor Detail

TableWithPuts

TableWithPuts(DatabaseProviderInterface dataSource,
              java.lang.String tableName,
              java.lang.String[] columns,
              int batchSize,
              int maxQueueLength,
              boolean autoFlush,
              boolean autoGrowBuffer)

Method Detail

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