org.dice_research.squirrel.collect

Class SqlBasedUriCollector.UriTableStatus

java.lang.Object

org.dice_research.squirrel.collect.SqlBasedUriCollector.UriTableStatus

Enclosing class:

SqlBasedUriCollector

protected static class SqlBasedUriCollector.UriTableStatus
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private Map<String,byte[]>	buffer
private int	bufferSize
private PreparedStatement	insertStmt
private String	tableName

Constructor Summary

Constructors

Constructor and Description
UriTableStatus(String tableName, PreparedStatement insertStmt, int bufferSize)

Method Summary

Modifier and Type	Method and Description
void	addUri(String uri, byte[] serializedUri)
void	commitPendingChanges()
static SqlBasedUriCollector.UriTableStatus	create(String tableName, Connection dbConnection, int bufferSize)
private void	execute_unsecured()
private void	executeAsBatch_unsecured() Deprecated.
String	getTableName()

Methods inherited from class java.lang.Object

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

Field Detail

tableName

private final String tableName

insertStmt

private final PreparedStatement insertStmt

buffer

private final Map<String,byte[]> buffer

bufferSize

private final int bufferSize

Constructor Detail

UriTableStatus

public UriTableStatus(String tableName,
                      PreparedStatement insertStmt,
                      int bufferSize)

Method Detail

create

public static SqlBasedUriCollector.UriTableStatus create(String tableName,
                                                         Connection dbConnection,
                                                         int bufferSize)
                                                  throws SQLException

Throws:

SQLException

addUri

public void addUri(String uri,
                   byte[] serializedUri)

commitPendingChanges

public void commitPendingChanges()

execute_unsecured

private void execute_unsecured()

executeAsBatch_unsecured

@Deprecated
private void executeAsBatch_unsecured()

Deprecated.

getTableName

public String getTableName()