diff --git a/src/java/org/apache/sqoop/manager/MySQLManager.java b/src/java/org/apache/sqoop/manager/MySQLManager.java
index d7abb44f..a817aa41 100644
--- a/src/java/org/apache/sqoop/manager/MySQLManager.java
+++ b/src/java/org/apache/sqoop/manager/MySQLManager.java
@@ -69,6 +69,14 @@ protected void initOptionDefaults() {
     }
   }
 
+  @Override
+  protected String getPrimaryKeyQuery(String tableName) {
+    return "SELECT column_name FROM INFORMATION_SCHEMA.COLUMNS "
+         + "WHERE TABLE_SCHEMA = (" + getSchemaQuery() + ") "
+         + "AND TABLE_NAME = '"+tableName+"' "
+         + "AND COLUMN_KEY = 'PRI'";
+  }
+
   @Override
   protected String getColNamesQuery(String tableName) {
     // Use mysql-specific hints and LIMIT to return fast