thrsafe

package
v0.0.0-...-8462f15 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 2, 2014 License: Apache-2.0, BSD-3-Clause, BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Overview

Thread safe engine for MyMySQL

In contrast to native engine:

  • one connection can be used by multiple gorutines,
  • if connection is idle pings are sent to the server (once per minute) to avoid timeout.

See documentation of mymysql/native for details

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New(proto, laddr, raddr, user, passwd string, db ...string) mysql.Conn

Types

type Conn

type Conn struct {
	mysql.Conn
	// contains filtered or unexported fields
}

func (*Conn) Begin

func (c *Conn) Begin() (mysql.Transaction, error)

func (*Conn) Clone

func (c *Conn) Clone() mysql.Conn

func (*Conn) Close

func (c *Conn) Close() error

func (*Conn) Connect

func (c *Conn) Connect() error

func (*Conn) Ping

func (c *Conn) Ping() error

func (*Conn) Prepare

func (c *Conn) Prepare(sql string) (mysql.Stmt, error)

func (*Conn) Query

func (c *Conn) Query(sql string, params ...interface{}) ([]mysql.Row, mysql.Result, error)

See mysql.Query

func (*Conn) QueryFirst

func (my *Conn) QueryFirst(sql string, params ...interface{}) (mysql.Row, mysql.Result, error)

See mysql.QueryFirst

func (*Conn) QueryLast

func (my *Conn) QueryLast(sql string, params ...interface{}) (mysql.Row, mysql.Result, error)

See mysql.QueryLast

func (*Conn) Reconnect

func (c *Conn) Reconnect() error

func (*Conn) Start

func (c *Conn) Start(sql string, params ...interface{}) (mysql.Result, error)

func (*Conn) Use

func (c *Conn) Use(dbname string) error

type Result

type Result struct {
	mysql.Result
	// contains filtered or unexported fields
}

func (*Result) End

func (res *Result) End() error

See mysql.End

func (*Result) GetFirstRow

func (res *Result) GetFirstRow() (mysql.Row, error)

See mysql.GetFirstRow

func (*Result) GetLastRow

func (res *Result) GetLastRow() (mysql.Row, error)

See mysql.GetLastRow

func (*Result) GetRow

func (res *Result) GetRow() (mysql.Row, error)

func (*Result) GetRows

func (res *Result) GetRows() ([]mysql.Row, error)

See mysql.GetRows

func (*Result) NextResult

func (res *Result) NextResult() (mysql.Result, error)

func (*Result) ScanRow

func (res *Result) ScanRow(row mysql.Row) error

type Stmt

type Stmt struct {
	mysql.Stmt
	// contains filtered or unexported fields
}

func (*Stmt) Delete

func (stmt *Stmt) Delete() error

func (*Stmt) Exec

func (stmt *Stmt) Exec(params ...interface{}) ([]mysql.Row, mysql.Result, error)

See mysql.Exec

func (*Stmt) ExecFirst

func (stmt *Stmt) ExecFirst(params ...interface{}) (mysql.Row, mysql.Result, error)

See mysql.ExecFirst

func (*Stmt) ExecLast

func (stmt *Stmt) ExecLast(params ...interface{}) (mysql.Row, mysql.Result, error)

See mysql.ExecLast

func (*Stmt) Reset

func (stmt *Stmt) Reset() error

func (*Stmt) Run

func (stmt *Stmt) Run(params ...interface{}) (mysql.Result, error)

func (*Stmt) SendLongData

func (stmt *Stmt) SendLongData(pnum int, data interface{}, pkt_size int) error

type Transaction

type Transaction struct {
	*Conn
	// contains filtered or unexported fields
}

func (*Transaction) Commit

func (tr *Transaction) Commit() error

func (*Transaction) Do

func (tr *Transaction) Do(st mysql.Stmt) mysql.Stmt

func (*Transaction) IsValid

func (tr *Transaction) IsValid() bool

func (*Transaction) Rollback

func (tr *Transaction) Rollback() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL