sql

README

SQL

One sql service for fns.

Features

• Global transaction
• Proxy
• Support master slaver kind
• Support cluster kind

Install

go get github.com/aacfactory/fns-contrib/databases/sql

Usage

Config

• Standalone type
  • masterSlaverMode = false
  • dsn size is one
• Master slaver type
  • masterSlaverMode = true
  • first of dsn is master, afters are slavers
• Cluster type
  • masterSlaverMode = false
  • all in dsn is members

Example:

sql:
  masterSlaverMode: false,
  driver: "postgres",
  dsn:
    - "username:password@tcp(ip:port)/databases"
  maxIdles: 0
  maxOpens: 0
  enableDebugLog: true
  gtmCleanUpSecond: 120
  isolation: 2

Import driver

import _ "github.com/go-sql-driver/mysql"

Deploy

app.Deply(sql.Service())

Proxy usage

See proxy.go

// begin transaction 
sql.BeginTransaction(ctx)
// commit transaction
sql.CommitTransaction(ctx)
// query
sql.Query(ctx, querySQL, ...)
// execute
sql.Execute(ctx, executeSQL, ...)

ORM usage

• postgres
• mysql

Documentation

Index

• Constants
• func BeginTransaction(ctx context.Context) (err errors.CodeError)
• func CommitTransaction(ctx context.Context) (err errors.CodeError)
• func Execute(ctx context.Context, query string, args ...interface{}) (affected int64, lastInsertId int64, err errors.CodeError)
• func RollbackTransaction(ctx context.Context) (err errors.CodeError)
• func Service() service.Service
• type Column
• type ColumnScanner
  • func NewColumnScanner(ct *sql.ColumnType) (scanner *ColumnScanner)
  • func (c ColumnScanner) Get(v interface{}) (err error)
  • func (c ColumnScanner) IsNil() (ok bool)
  • func (c ColumnScanner) Name() (v string)
  • func (c ColumnScanner) RawValue() (raw []byte)
  • func (c *ColumnScanner) Scan(src interface{}) error
  • func (c ColumnScanner) Type() (typ string)
• type ColumnType
• type FieldColumn
• type NullJson
  • func (v *NullJson) Scan(src interface{}) error
• type NullSQLRaw
  • func (v *NullSQLRaw) Scan(src interface{}) error
• type Row
• type Rows
  • func Query(ctx context.Context, query string, args ...interface{}) (v Rows, err errors.CodeError)

Constants

const (
	StringType  = ColumnType("string")
	IntType     = ColumnType("int")
	FloatType   = ColumnType("float")
	BytesType   = ColumnType("bytes")
	JsonType    = ColumnType("json")
	BoolType    = ColumnType("bool")
	TimeType    = ColumnType("time")
	UnknownType = ColumnType("unknown")
)

Functions

func BeginTransaction

func BeginTransaction(ctx context.Context) (err errors.CodeError)

func CommitTransaction

func CommitTransaction(ctx context.Context) (err errors.CodeError)

func Execute

func Execute(ctx context.Context, query string, args ...interface{}) (affected int64, lastInsertId int64, err errors.CodeError)

func RollbackTransaction

func RollbackTransaction(ctx context.Context) (err errors.CodeError)

func Service

func Service() service.Service

Types

type Column

type Column interface {
	Type() (typ string)
	Name() (v string)
	IsNil() (ok bool)
	Get(v interface{}) (err error)
	RawValue() (raw []byte)
}

type ColumnScanner

type ColumnScanner struct {
	// contains filtered or unexported fields
}

func NewColumnScanner

func NewColumnScanner(ct *sql.ColumnType) (scanner *ColumnScanner)

func (ColumnScanner) Get

func (c ColumnScanner) Get(v interface{}) (err error)

func (ColumnScanner) IsNil

func (c ColumnScanner) IsNil() (ok bool)

func (ColumnScanner) Name

func (c ColumnScanner) Name() (v string)

func (ColumnScanner) RawValue

func (c ColumnScanner) RawValue() (raw []byte)

func (*ColumnScanner) Scan

func (c *ColumnScanner) Scan(src interface{}) error

func (ColumnScanner) Type

func (c ColumnScanner) Type() (typ string)

type ColumnType

type ColumnType string

type FieldColumn

type FieldColumn struct {
	Kind      string
	FieldType reflect.Type
	Column    *Column
}

type NullJson

type NullJson struct {
	Json  json.RawMessage
	Valid bool
}

func (*NullJson) Scan

func (v *NullJson) Scan(src interface{}) error

type NullSQLRaw

type NullSQLRaw struct {
	Raw   sql.RawBytes
	Valid bool
}

func (*NullSQLRaw) Scan

func (v *NullSQLRaw) Scan(src interface{}) error

type Row

type Row interface {
	json.Marshaler
	json.Unmarshaler
	Empty() (ok bool)
	Columns() (columns []Column)
	Column(name string, value interface{}) (has bool, err error)
}

type Rows

type Rows interface {
	json.Marshaler
	json.Unmarshaler
	Empty() (ok bool)
	Size() int
	Next() (v Row, has bool)
}

func Query

func Query(ctx context.Context, query string, args ...interface{}) (v Rows, err errors.CodeError)