added: database interfaces, wrappers, mocks, and create table tests

Author: kmacmcfarlane

.idea/workspace.xml

@@ -1,13 +1,20 @@
 .DEFAULT_GOAL := all
 
-all: |build test
+all: |build_deps test_deps build test
+
+build_deps:
+	go get github.com/lib/pq
 
 test_deps:
 	go get -u github.com/onsi/ginkgo/ginkgo
 	go get -u github.com/onsi/gomega/...
+	@go get github.com/vektra/mockery/.../
 
 build:
 	go build -o ./bin/csv-2-postgresql ./csv-2-postgresql
 
-test:
+build_mocks:
+	@mockery -all -dir postgresql/ -output mock -case=underscore
+
+test: build_mocks
 	ginkgo -r ./

Makefile

@@ -1,12 +1,12 @@
 package main
 
-import "github.com/kmacmcfarlane/csv-2-postgresql-go/schema"
-
 // DatabaseWriter defines a generic interface to a database
 type DatabaseWriter interface {
 
+	// CreateDatabase creates a database if it does not exist
+	CreateDatabase(name string) (err error)
 	// CreateTable instantiates a table compatible with the given schema
-	CreateTable(name string, schema schema.Schema) error
+	CreateTable(name string) error
 	// Insert adds a record to the table
 	Insert(values []string) error
 }

bin/csv-2-postgresql

@@ -1,5 +1,47 @@
 package main
 
-func main(){
+import (
+	"database/sql"
+	"flag"
+	"fmt"
+	"github.com/kmacmcfarlane/csv-2-postgresql-go/postgresql"
+	"os"
+)
 
+func main() {
+
+	// Parse arguments
+	args := flag.Args()
+
+	if len(args) != 1 || len(args) != 2 {
+		usage()
+		os.Exit(1)
+	}
+
+	inputFile := args[0]
+	databaseName := args[1]
+
+	// Connect to DB
+	connectionString := fmt.Sprintf("user=postgres dbname=%s sslmode=verify-full", databaseName)
+
+	db, err := sql.Open("postgres", connectionString)
+
+	if nil != err {
+		panic(err)
+	}
+
+	defer db.Close()
+
+	sqlWrapper := postgresql.NewSQLWrapper(db)
+
+	// Parse schema of input
+
+	// Insert data to database
+	
+}
+
+func usage(){
+
+	println("Usage:")
+	println("csv-2-postgresql input_file.csv [database_name]")
 }

csv-2-postgresql/database_writer.go

@@ -37,8 +37,6 @@ func (p *Parser) ParseSchema() (result schema.Schema, err error) {
 		return result, err
 	}
 
-	result.Headers = headers
-
 	// Get the next line to determine the type of each field
 	p.firstRecord, err = p.reader.Read() // save this first record to avoid having to re-init the reader somehow
 

csv-2-postgresql/main.go

@@ -9,7 +9,7 @@ import (
 	"strings"
 )
 
-var _ = Describe("Schema", func() {
+var _ = Describe("Parser", func() {
 
 
 	Describe("CSVParser", func(){

csv/parser.go

@@ -0,0 +1,13 @@
+package postgresql_test
+
+import (
+	"testing"
+
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+)
+
+func TestPostgresql(t *testing.T) {
+	RegisterFailHandler(Fail)
+	RunSpecs(t, "Postgresql Suite")
+}