public abstract class AbstractTablePartWorker extends Object implements Callable<ConversionResult>
| Modifier and Type | Class and Description |
|---|---|
static class |
AbstractTablePartWorker.DMLOperation |
| Modifier and Type | Field and Description |
|---|---|
protected CloudSpannerConnection |
connection |
protected AbstractTablePartWorker.DMLOperation |
operation |
protected net.sf.jsqlparser.statement.select.Select |
select |
| Modifier and Type | Method and Description |
|---|---|
ConversionResult |
call() |
protected abstract String |
createSQL() |
protected void |
genericRun() |
protected abstract List<String> |
getColumnNames() |
protected long |
getEstimatedRecordCount(net.sf.jsqlparser.statement.select.Select select) |
long |
getRecordCount() |
protected abstract net.sf.jsqlparser.schema.Table |
getTable() |
protected boolean |
isExtendedMode(long batchSize) |
protected final CloudSpannerConnection connection
protected final net.sf.jsqlparser.statement.select.Select select
protected final AbstractTablePartWorker.DMLOperation operation
public ConversionResult call()
call in interface Callable<ConversionResult>protected void genericRun()
throws SQLException
SQLExceptionprotected abstract List<String> getColumnNames() throws SQLException
SQLExceptionprotected abstract net.sf.jsqlparser.schema.Table getTable()
protected abstract String createSQL() throws SQLException
SQLExceptionprotected long getEstimatedRecordCount(net.sf.jsqlparser.statement.select.Select select)
throws SQLException
SQLExceptionprotected boolean isExtendedMode(long batchSize)
throws SQLException
SQLExceptionpublic long getRecordCount()
Copyright © 2017. All rights reserved.