org.apache.ignite.cache.store.jdbc.dialect

Class MySQLDialect

java.lang.Object

org.apache.ignite.cache.store.jdbc.dialect.BasicJdbcDialect

org.apache.ignite.cache.store.jdbc.dialect.MySQLDialect

All Implemented Interfaces:

Serializable, JdbcDialect

public class MySQLDialect
extends BasicJdbcDialect

A dialect compatible with the MySQL database.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.ignite.cache.store.jdbc.dialect.BasicJdbcDialect

DFLT_MAX_PARAMS_CNT, maxParamsCnt

Constructor Summary

Constructors

Constructor and Description
MySQLDialect()

Method Summary

Modifier and Type	Method and Description
String	escape(String ident)
int	getFetchSize() Gives the JDBC driver a hint how many rows should be fetched from the database when more rows are needed.
boolean	hasMerge()
String	loadCacheSelectRangeQuery(String fullTblName, Collection<String> keyCols) Construct query to get ranges bounds.
String	mergeQuery(String fullTblName, Collection<String> keyCols, Collection<String> uniqCols) Construct merge query.

Methods inherited from class org.apache.ignite.cache.store.jdbc.dialect.BasicJdbcDialect

getMaxParameterCount, insertQuery, loadCacheQuery, loadCacheRangeQuery, loadQuery, mkString, mkString, mkString, removeQuery, repeat, setMaxParameterCount, updateQuery

Methods inherited from class java.lang.Object

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

Constructor Detail

MySQLDialect

public MySQLDialect()

Method Detail

escape

public String escape(String ident)

Specified by:

escape in interface JdbcDialect

Overrides:

escape in class BasicJdbcDialect

Parameters:

ident - SQL identifier to escape.

Returns:

Escaped SQL identifier.

loadCacheSelectRangeQuery

public String loadCacheSelectRangeQuery(String fullTblName,
                                        Collection<String> keyCols)

Construct query to get ranges bounds.

Specified by:

loadCacheSelectRangeQuery in interface JdbcDialect

Overrides:

loadCacheSelectRangeQuery in class BasicJdbcDialect

Parameters:

fullTblName - Full table name.

keyCols - Database key columns for order.

Returns:

Query for select count.

hasMerge

public boolean hasMerge()

Specified by:

hasMerge in interface JdbcDialect

Overrides:

hasMerge in class BasicJdbcDialect

Returns:

True if database support merge operation.

mergeQuery

public String mergeQuery(String fullTblName,
                         Collection<String> keyCols,
                         Collection<String> uniqCols)

Construct merge query.

Specified by:

mergeQuery in interface JdbcDialect

Overrides:

mergeQuery in class BasicJdbcDialect

Parameters:

fullTblName - Full table name.

keyCols - Database key columns.

uniqCols - Database unique value columns.

Returns:

Merge query.

getFetchSize

public int getFetchSize()

Gives the JDBC driver a hint how many rows should be fetched from the database when more rows are needed. If the value specified is zero, then the hint is ignored. The default value is zero.

Specified by:

getFetchSize in interface JdbcDialect

Overrides:

getFetchSize in class BasicJdbcDialect

Returns:

The fetch size for result sets.