sql

Documentation

Index

• func ExecuteWithConn(conn *sql.DB, command string) error
• func FetchRawGenerator(conn *sql.DB, command string) <-chan *GenRow
• func FetchRawWithConn(conn *sql.DB, command string) ([][]sql.RawBytes, error)
• func FetchWithConn(conn *sql.DB, command string, ...) ([]interface{}, error)
• func PushBulk(conn *sql.DB, command string, items []string) error
• type DataHandler
• type GenRow

Functions

func ExecuteWithConn

func ExecuteWithConn(conn *sql.DB, command string) error

ExecuteWithConn used to execute sql command such as insert, delete

func FetchRawGenerator

func FetchRawGenerator(conn *sql.DB, command string) <-chan *GenRow

FetchRawGenerator used to query data with a established connection

func FetchRawWithConn

func FetchRawWithConn(conn *sql.DB, command string) ([][]sql.RawBytes, error)

FetchRawWithConn (NOT SUGGEST TO USE DUE TO MEMORY BUG)used to query data with a established connection

func FetchWithConn

func FetchWithConn(conn *sql.DB, command string, rowHandel func(rowIndex int, row []sql.RawBytes) (interface{}, error)) ([]interface{}, error)

FetchWithConn used to query data with a established connection

func PushBulk

func PushBulk(conn *sql.DB, command string, items []string) error

PushBulk used to push bulk data to db

Types

type DataHandler

type DataHandler func(rowIndex int, row []sql.RawBytes) (interface{}, error)

DataHandler used process the raw data to target object

type GenRow

type GenRow struct {
	Err  error
	Data []sql.RawBytes
}

GenRow used to process the raw data GenRow