Fix returning error in postgres code

lukasmartinelli · Feb 28, 2016 · e353ba7 · e353ba7
1 parent 60d98cd
commit e353ba7
Showing 1 changed file with 2 additions and 10 deletions.
diff --git a/postgres.go b/postgres.go
@@ -104,11 +104,7 @@ func createJSONTable(db *sql.DB, schema string, tableName string, column string)
 	tableSchema := fmt.Sprintf("CREATE TABLE IF NOT EXISTS %s (%s JSON)", fullyQualifiedTable, column)
 
 	statement, err := db.Prepare(tableSchema)
-	if err == nil {
-		return statement, err
-	}
-
-	return statement, nil
+	return statement, err
 }
 
 //create table with TEXT columns
@@ -122,9 +118,5 @@ func createTable(db *sql.DB, schema string, tableName string, columns []string)
 	tableSchema := fmt.Sprintf("CREATE TABLE IF NOT EXISTS %s (%s)", fullyQualifiedTable, columnDefinitions)
 
 	statement, err := db.Prepare(tableSchema)
-	if err == nil {
-		return statement, err
-	}
-
-	return statement, nil
+	return statement, err
 }