GO Postgres

go-postgres library provide NoSQL functionality which can execute queries with pool of connections.

What is this repository for?

• Establish postgres connection pool
• Execute the SQL queries

How do I get set up?

Establish Postgres Connection

package main

import (
	"fmt"
	"bitbucket.org/mybudget-dev/go-postgres"
)

func main() {
	conf := gopostgres.DBConfig{
		User:     "User",
		Password: "Password",
		Host:     "<<Host>>",
		Port:     "<<PORT>>",
		Database: "Database",
	}
	DBPool, err := gopostgres.NewDBPool(conf)
	if err != nil {
		fmt.Println(err.Error())
		return
	}
	defer DBPool.Close()

}

Postgres Insert

package main

import (
	"context"
	"fmt"
	"bitbucket.org/mybudget-dev/go-postgres"
)

func main() {
	conf := gopostgres.DBConfig{
		User:     "User",
		Password: "Password",
		Host:     "<<Host>>",
		Port:     "<<PORT>>",
		Database: "Database",
	}
	sql, err := gopostgres.NewDBPool(conf)
	if err != nil {
		fmt.Println(err.Error())
		return
	}
	defer sql.Close()

	// context 
	ctx := context.Background()

	// insert data into postgres
	data := "data"
	// Transaction opt is optional and you can configure DB isolation levels  
	transaction, err := sql.BeginTransaction(ctx, nil)
	if err != nil {
		return
	}
	userQuery :=
		fmt.Sprintf(`INSERT INTO "%s"(data) VALUES($1)`,
			"table")
	statement, err := transaction.PrepareContext(ctx, userQuery)
	if statement != nil {
		defer statement.Close()
	} else {
		fmt.Println(err.Error())
		return
	}
	if err != nil {
		fmt.Println(err.Error())
		return
	}
	_, err = statement.ExecContext(ctx, &data)
	if err != nil {
		if errorTransaction := transaction.Rollback(); errorTransaction != nil {
			fmt.Println(err.Error())
		}
	}
}

Postgres Get

package main

import (
	"context"
	"fmt"
	"bitbucket.org/mybudget-dev/go-postgres"
)

func main() {
	conf := gopostgres.DBConfig{
		User:     "User",
		Password: "Password",
		Host:     "<<Host>>",
		Port:     "<<PORT>>",
		Database: "Database",
	}
	sql, err := gopostgres.NewDBPool(conf)
	if err != nil {
		fmt.Println(err.Error())
		return
	}
	defer sql.Close()

	// context 
	ctx := context.Background()

	// get data from postgres
	key := 1
	query := fmt.Sprintf(`SELECT data FROM "%s" WHERE key=$1  ;`, "table")
	statementOfLocation, err := sql.Prepare(ctx, query)
	if statementOfLocation != nil {
		defer statementOfLocation.Close()
	}
	if err != nil {
		fmt.Println(err.Error())
		return
	}

	row, err := statementOfLocation.QueryContext(ctx, key)
	if row != nil {
		defer row.Close()
	}
	if err != nil {
		fmt.Println(err.Error())
		return
	}

	var data interface{}
	for row.Next() {
		err = row.Scan(&data)
		if err != nil {
			fmt.Println(err.Error())
			return
		}
	}
}