mirror of
https://github.com/apache/sqoop.git
synced 2025-05-03 22:20:52 +08:00
SQOOP-1400: Failed to import data using mysql-connector-java-5.1.17.jar
(Richard via Jarek Jarcec Cecho)
This commit is contained in:
parent
159e924d4f
commit
28f5aa03ba
@ -63,22 +63,6 @@ public MySQLManager(final SqoopOptions opts) {
|
||||
super(DRIVER_CLASS, opts);
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void initOptionDefaults() {
|
||||
if (options.getFetchSize() == null) {
|
||||
LOG.info("Preparing to use a MySQL streaming resultset.");
|
||||
options.setFetchSize(Integer.MIN_VALUE);
|
||||
} else if (
|
||||
!options.getFetchSize().equals(Integer.MIN_VALUE)
|
||||
&& !options.getFetchSize().equals(0)) {
|
||||
LOG.info("Argument '--fetch-size " + options.getFetchSize()
|
||||
+ "' will probably get ignored by MySQL JDBC driver.");
|
||||
// see also
|
||||
// http://dev.mysql.com/doc/refman/5.5/en
|
||||
// /connector-j-reference-implementation-notes.html
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
protected String getPrimaryKeyQuery(String tableName) {
|
||||
return "SELECT column_name FROM INFORMATION_SCHEMA.COLUMNS "
|
||||
|
Loading…
Reference in New Issue
Block a user