Documentation ¶
Index ¶
- func QuoteStr(str string) string
- func Transpose(matrix [][]interface{}) [][]interface{}
- type Conn
- func (c *Conn) BulkExecute(sql string, data *bytes.Buffer) error
- func (c *Conn) BulkInsert(schema, table string, data *bytes.Buffer) (err error)
- func (c *Conn) BulkQuery(sql string, data *bytes.Buffer) error
- func (c *Conn) BulkSelect(schema, table string, data *bytes.Buffer) (err error)
- func (c *Conn) Commit() error
- func (c *Conn) DisableAutoCommit()
- func (c *Conn) Disconnect()
- func (c *Conn) EnableAutoCommit()
- func (c *Conn) Execute(sql string, args ...interface{}) (map[string]interface{}, error)
- func (c *Conn) FetchChan(sql string, args ...interface{}) (<-chan []interface{}, error)
- func (c *Conn) FetchSlice(sql string, args ...interface{}) (res [][]interface{}, err error)
- func (c *Conn) GetSessionAttr() (map[string]interface{}, error)
- func (c *Conn) QuoteIdent(ident string) string
- func (c *Conn) Rollback() error
- func (c *Conn) StreamExecute(origSQL string, data <-chan []byte) error
- func (c *Conn) StreamInsert(schema, table string, data <-chan []byte) (err error)
- func (c *Conn) StreamQuery(origSQL string, data chan<- []byte) (int64, error)
- func (c *Conn) StreamSelect(schema, table string, data chan<- []byte) (int64, error)
- type ConnConf
- type DataType
- type Proxy
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Conn ¶
type Conn struct { Conf ConnConf SessionID uint64 Stats map[string]int // contains filtered or unexported fields }
func (*Conn) BulkInsert ¶
func (*Conn) BulkSelect ¶
func (*Conn) DisableAutoCommit ¶
func (c *Conn) DisableAutoCommit()
func (*Conn) Disconnect ¶
func (c *Conn) Disconnect()
func (*Conn) EnableAutoCommit ¶
func (c *Conn) EnableAutoCommit()
func (*Conn) Execute ¶
TODO change optional args into an ExecConf struct Optional args are binds, default schema, colDefs, isColumnar flag
func (*Conn) FetchSlice ¶
For large datasets use FetchChan to avoid buffering all the data in memory
func (*Conn) GetSessionAttr ¶
func (*Conn) QuoteIdent ¶
func (*Conn) StreamInsert ¶
func (*Conn) StreamQuery ¶
Click to show internal directories.
Click to hide internal directories.