updating queries

Author: matttm

query.go

@@ -9,14 +9,14 @@ var (
 			SELECT TABLE_NAME
 			FROM INFORMATION_SCHEMA.TABLES 
 			WHERE TABLE_TYPE = 'BASE TABLE' AND TABLE_SCHEMA = '%s'
-			AND TABLE_ROWS < 200 AND TABLE_ROWS > 35;
+			AND TABLE_ROWS < 300 AND TABLE_ROWS > 35;
 			`, db)
 	}
 	SHOW_CREATE = func(dbName, tableName string) string {
 		return fmt.Sprintf("SHOW CREATE TABLE %s.%s;", dbName, tableName)
 	}
 	SELECT_COLUMNS = func(tableName string) string {
-		return fmt.Sprintf("SELECT COLUMN_NAME, DATA_TYPE FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME='%s';", tableName)
+		return fmt.Sprintf("SELECT DISTINCT COLUMN_NAME, DATA_TYPE FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME='%s';", tableName)
 	}
 	DROP_DB = func(dbName string) string {
 		return fmt.Sprintf("DROP DATABASE IF EXISTS %s", dbName)