org.kuali.common.impex.data.impl.mysql
Class MySqlProducer

java.lang.Object
  org.kuali.common.impex.data.impl.AbstractSqlProducer
      org.kuali.common.impex.data.impl.mysql.MySqlProducer

All Implemented Interfaces:

SqlProducer

public class MySqlProducer
extends AbstractSqlProducer

Field Summary

static String	DATE_VALUE_SUFFIX
static String	SUPPORTED_VENDOR

Fields inherited from class org.kuali.common.impex.data.impl.AbstractSqlProducer

DEFAULT_BATCH_ROW_COUNT_LIMIT, DEFAULT_DATA_SIZE_LIMIT, OUTPUT_DATE_FORMAT

Constructor Summary

MySqlProducer()

Method Summary

protected String	buildBatchSql(List<DataBean> rowBeans)
protected String	getEscapedValue(Column column, String token)
protected String	getPrefix(Table table, MpxHeaderData headerData)
List<String>	getSql(Table table, MpxHeaderData headerData, BufferedReader reader) Read data lines from the .mpx file and combine them into batched up, INSERT INTO sql statements.
protected String	getSqlValue(DataBean data, SimpleDateFormat dateFormat)

Methods inherited from class org.kuali.common.impex.data.impl.AbstractSqlProducer

batchLimitReached, buildRowData, getBatchDataSizeLimit, getBatchRowCountLimit, getDate, isDataTypeTextType, processToken, setBatchDataSizeLimit, setBatchRowCountLimit

Methods inherited from class java.lang.Object

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

Field Detail

SUPPORTED_VENDOR

public static final String SUPPORTED_VENDOR

See Also:

Constant Field Values

DATE_VALUE_SUFFIX

public static final String DATE_VALUE_SUFFIX

See Also:

Constant Field Values

Constructor Detail

MySqlProducer

public MySqlProducer()

Method Detail

getSql

public List<String> getSql(Table table,
                           MpxHeaderData headerData,
                           BufferedReader reader)
                    throws IOException

Read data lines from the .mpx file and combine them into batched up, INSERT INTO sql statements. Individual data lines are merged together into SQL statements 50 lines at a time or 50K in length whichever comes first.

Throws:

IOException

buildBatchSql

protected String buildBatchSql(List<DataBean> rowBeans)

getSqlValue

protected String getSqlValue(DataBean data,
                             SimpleDateFormat dateFormat)

getPrefix

protected String getPrefix(Table table,
                           MpxHeaderData headerData)

getEscapedValue

protected String getEscapedValue(Column column,
                                 String token)

Specified by:

getEscapedValue in class AbstractSqlProducer