creating in mem db

Author: matttm

Diff for: database.go

@@ -50,7 +50,6 @@ func InitEmptyDatabase() *sql.DB {
 		fmt.Println("Error while connecting to database")
 		panic(err)
 	}
-	log.Println("Database provider init")
 	return db
 
 }
@@ -87,7 +86,12 @@ func QueryForTwoColumns(db *sql.DB, query string) [][2]string {
 	return props
 }
 func Populate(db *sql.DB, query string, inserts []string) {
-	_, err := db.Exec(query)
+	_, err := db.Exec("USE IMPOSTER")
+	if err != nil {
+		fmt.Println("Error while connecting to database")
+		panic(err)
+	}
+	_, err = db.Exec(query)
 	if err != nil {
 		fmt.Println("Error while connecting to database")
 		panic(err)

Diff for: inmemory-driver.go

@@ -21,8 +21,7 @@ func (factory) Resolve(name string, options *driver.Options) (string, sql.Databa
 
 func createTestDatabase() *memory.Database {
 	const (
-		dbName    = "mydb"
-		tableName = "mytable"
+		dbName = "IMPOSTER"
 	)
 
 	db := memory.NewDatabase(dbName)

Diff for: main.go

@@ -55,8 +55,9 @@ func main() {
 	for _, v := range inserts {
 		log.Println(v)
 	}
-	var provider *sql.DB = InitEmptyDatabase()
-	Populate(provider, createCommand, inserts)
+	var memdn *sql.DB = InitEmptyDatabase()
+	log.Println("Database provider init")
+	Populate(memdn, createCommand, inserts)
 
 	// start proxying
 	socket, err := net.Listen("tcp", "127.0.0.1:3307")
@@ -70,7 +71,7 @@ func main() {
 		if err != nil {
 			log.Fatalf("failed to accept connection: %s", err.Error())
 		}
-		go handleConn(originSocket, provider)
+		go handleConn(originSocket, memdn)
 	}
 
 }

Diff for: sql-manipulator.go

@@ -8,7 +8,7 @@ import (
 
 func CreateSelectInsertionFromSchema(schemaName, tableName string, columns [][2]string) string {
 	var sb strings.Builder
-	write(&sb, `SELECT CONCAT('INSERT INTO ', '%s.%s ', 'SET ', `, schemaName, tableName)
+	write(&sb, `SELECT CONCAT('INSERT INTO %s.%s SET ', `, "IMPOSTER" /*schschemaName*/, tableName)
 	for i, v := range columns {
 		name := v[0]
 		_type := v[1]
@@ -17,7 +17,7 @@ func CreateSelectInsertionFromSchema(schemaName, tableName string, columns [][2]
 		setVal := `x.%s`
 		if nullVal != 0 {
 			isNull = "CAST(x.%s AS CHAR)"
-			setVal = "CONCAT('\"', x.%s, '\"')"
+			setVal = "QUOTE(x.%s)"
 		}
 		isNull = fmt.Sprintf(isNull, name)
 		setVal = fmt.Sprintf(setVal, name)