fix alter statements

putdotio · Sep 11, 2018 · 5a5b6d4 · 5a5b6d4
1 parent 9d66b76
commit 5a5b6d4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/internal/inserter/eventinserter/eventinserter.go b/internal/inserter/eventinserter/eventinserter.go
@@ -110,7 +110,8 @@ func (i EventInserter) AlterTableSQL(existingColumns map[string]struct{}, def pr
 			sb.WriteString(string(pname))
 			sb.WriteRune(' ')
 			sb.WriteString(ptype.ColumnType())
+			sb.WriteRune(',')
 		}
 	}
-	return sb.String(), nil
+	return strings.TrimRight(sb.String(), ","), nil
 }
diff --git a/internal/inserter/userinserter/userinserter.go b/internal/inserter/userinserter/userinserter.go
@@ -116,7 +116,8 @@ func (i UserInserter) AlterTableSQL(existingColumns map[string]struct{}, def pro
 			sb.WriteString(string(pname))
 			sb.WriteRune(' ')
 			sb.WriteString(ptype.ColumnType())
+			sb.WriteRune(',')
 		}
 	}
-	return sb.String(), nil
+	return strings.TrimRight(sb.String(), ","), nil
 }