Merge pull request ClickHouse#420 from f0rtung/insert-select-query

Support INSERT INTO ... SELECT query

Author: kshvakov

helpers.go

@@ -29,6 +29,7 @@ func numInput(query string) int {
 		and           = newMatcher("and")
 		from          = newMatcher("from")
 		join          = newMatcher("join")
+		subSelect     = newMatcher("select")
 	)
 	for {
 		if char, _, err := reader.ReadRune(); err == nil {
@@ -74,7 +75,7 @@ func numInput(query string) int {
 				keyword = true
 			default:
 				if limit.matchRune(char) || offset.matchRune(char) || like.matchRune(char) ||
-					in.matchRune(char) || from.matchRune(char) || join.matchRune(char) {
+					in.matchRune(char) || from.matchRune(char) || join.matchRune(char) || subSelect.matchRune(char) {
 					keyword = true
 				} else if between.matchRune(char) {
 					keyword = true
@@ -133,6 +134,8 @@ func quote(v driver.Value) string {
 		return "'" + strings.NewReplacer(`\`, `\\`, `'`, `\'`).Replace(v) + "'"
 	case time.Time:
 		return formatTime(v)
+	case nil:
+		return "null"
 	}
 	return fmt.Sprint(v)
 }

stmt.go

@@ -127,6 +127,7 @@ func (stmt *stmt) bind(args []driver.NamedValue) (string, []ExternalTable) {
 		in             = newMatcher("in")
 		from           = newMatcher("from")
 		join           = newMatcher("join")
+		subSelect      = newMatcher("select")
 		externalTables = make([]ExternalTable, 0)
 	)
 	switch {
@@ -178,7 +179,7 @@ func (stmt *stmt) bind(args []driver.NamedValue) (string, []ExternalTable) {
 						keyword = true
 					default:
 						if limit.matchRune(char) || offset.matchRune(char) || like.matchRune(char) ||
-							in.matchRune(char) || from.matchRune(char) || join.matchRune(char) {
+							in.matchRune(char) || from.matchRune(char) || join.matchRune(char) || subSelect.matchRune(char) {
 							keyword = true
 						} else if between.matchRune(char) {
 							keyword = true