README
¶
ksql
A simple extension to the golang database/sql package that facilitates getting row columns by name. The goal is to keep the existing sql package interface intact, yet allow the use of additional methods to satisfy the added functionality. This allows a seamless swap of the database/sql package with this one.
Feature highlights:
- Internal pool of database connections that allows getting a connection by name, and not have to keep a global pointer
- Support for queries with arbitrary number of result columns, get what you need.
- Get the last row of results even after the
Rowsare closed.
Install
go get github.com/kahoon/ksql
Usage
package main
import (
"fmt"
"log"
sql "github.com/kahoon/ksql"
_ "github.com/lib/pq"
)
// >>CHANGE<<
const (
HOSTNAME string = "192.168.1.10"
DATABASE = "test"
USER = "postgres"
PASSWORD = "postgres"
)
var (
drop = "drop table if exists people"
schema = "create table people (id integer not null,name text not null,married boolean not null,last_modified timestamp not null,primary key(id))"
data = []string{
"insert into people values (1,'John Doe','f','1980-12-01 01:02:03')",
"insert into people values (2,'Jane Doe','t','1999-12-01 01:02:03')",
}
query = "select * from people"
)
func populate() {
db, ok := sql.Get("master")
if !ok {
log.Fatalf("Database doesn't exist!\n")
}
_, err := db.Exec(drop)
if err != nil {
log.Fatal(err)
}
_, err = db.Exec(schema)
if err != nil {
log.Fatal(err)
}
for _, value := range data {
_, err = db.Exec(value)
if err != nil {
log.Fatal(err)
}
}
}
func main() {
// create a connection and name it
db, err := sql.New("master", "postgres", fmt.Sprintf("postgres://%s:%s@%s/%s?sslmode=disable", USER, PASSWORD, HOSTNAME, DATABASE))
if err != nil {
log.Fatal(err)
}
// close all open database on exit
defer sql.Close()
// populate the schema
populate()
// query the data
rows, err := db.Query(query)
if err != nil {
log.Fatalf("select failed %v", err)
}
for rows.Next() {
id, err := rows.GetInteger("id")
if err != nil {
log.Fatal(err)
}
name, err := rows.GetString("name")
if err != nil {
log.Fatal(err)
}
last, err := rows.GetTime("last_modified")
if err != nil {
log.Fatal(err)
}
log.Println(id, name, last)
}
if err := rows.Err(); err != nil {
log.Fatal(err)
}
defer rows.Close()
row := db.QueryRow("select * from people where id=1")
id, err := row.GetInteger("id")
if err != nil {
log.Fatal(err)
}
name, err := row.GetString("name")
if err != nil {
log.Fatal(err)
}
log.Println(id,name)
}
Documentation
¶
Overview ¶
A simple extension to the golang database/sql package that facilitates getting row columns by name. The goal is to keep the existing sql package interface intact, yet allow the use of additional methods to satisfy the added functionality. This allows a seamless swap of the database/sql package with this one. Methods not list are directly inherited from database/sql
Index ¶
- Variables
- func Close()
- func Databases() []string
- type DB
- type Row
- func (r *Row) GetBoolean(column string) (bool, error)
- func (r *Row) GetDouble(column string) (float64, error)
- func (r *Row) GetInteger(column string) (int64, error)
- func (r *Row) GetString(column string) (string, error)
- func (r *Row) GetTime(column string) (time.Time, error)
- func (r *Row) Scan(dest ...interface{}) error
- type Rows
- func (rs *Rows) Err() error
- func (rs *Rows) GetBoolean(column string) (bool, error)
- func (rs *Rows) GetDouble(column string) (float64, error)
- func (rs *Rows) GetInteger(column string) (int64, error)
- func (rs *Rows) GetString(column string) (string, error)
- func (rs *Rows) GetTime(column string) (time.Time, error)
- func (rs *Rows) Next() bool
- type Stmt
- type Tx
Constants ¶
This section is empty.
Variables ¶
var ( ErrNoRows = sql.ErrNoRows ErrDupConnName = errors.New("ksql: duplicate database connection name") ErrColumnNotFound = errors.New("ksql: column not found in result") ErrInvalidColumnTypeConversion = errors.New("ksql: invalid column type conversion") )
Errors
Functions ¶
Types ¶
type DB ¶
Inherit database/sql.DB
type Row ¶
type Row struct {
// contains filtered or unexported fields
}
func (*Row) GetBoolean ¶
Get the boolean value in this row by column name
func (*Row) GetInteger ¶
Get the integer value in this row by column name
type Rows ¶
Inherit database/sql.Rows
func (*Rows) GetBoolean ¶
Get the boolean value in this row by column name
func (*Rows) GetInteger ¶
Get the integer value in this row by column name
Source Files
Directories