本文整理汇总了Golang中github.com/flike/kingshard/backend.BackendConn类的典型用法代码示例。如果您正苦于以下问题:Golang BackendConn类的具体用法?Golang BackendConn怎么用?Golang BackendConn使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了BackendConn类的4个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: executeInNode
func (c *ClientConn) executeInNode(conn *backend.BackendConn, sql string, args []interface{}) ([]*mysql.Result, error) {
var state string
startTime := time.Now().UnixNano()
r, err := conn.Execute(sql, args...)
if err != nil {
state = "ERROR"
} else {
state = "OK"
}
execTime := float64(time.Now().UnixNano()-startTime) / float64(time.Millisecond)
if strings.ToLower(c.proxy.logSql[c.proxy.logSqlIndex]) != golog.LogSqlOff &&
execTime > float64(c.proxy.slowLogTime[c.proxy.slowLogTimeIndex]) {
c.proxy.counter.IncrSlowLogTotal()
golog.OutputSql(state, "%.1fms - %s->%s:%s",
execTime,
c.c.RemoteAddr(),
conn.GetAddr(),
sql,
)
}
if err != nil {
return nil, err
}
return []*mysql.Result{r}, err
}
开发者ID:snower,项目名称:kingshard,代码行数:27,代码来源:conn_query.go
示例2: handleUseDB
func (c *ClientConn) handleUseDB(dbName string) error {
var co *backend.BackendConn
var err error
if len(dbName) == 0 {
return fmt.Errorf("must have database, the length of dbName is zero")
}
if c.schema == nil {
return mysql.NewDefaultError(mysql.ER_NO_DB_ERROR)
}
nodeName := c.schema.rule.DefaultRule.Nodes[0]
n := c.proxy.GetNode(nodeName)
//get the connection from slave preferentially
co, err = n.GetSlaveConn()
if err != nil {
co, err = n.GetMasterConn()
}
defer c.closeConn(co, false)
if err != nil {
return err
}
if err = co.UseDB(dbName); err != nil {
return err
}
c.db = dbName
return c.writeOK(nil)
}
开发者ID:CrocdileChan,项目名称:kingshard,代码行数:30,代码来源:conn_use.go
示例3: closeConn
func (c *ClientConn) closeConn(conn *backend.BackendConn, rollback bool) {
if c.isInTransaction() {
return
}
if rollback {
conn.Rollback()
}
conn.Close()
}
开发者ID:velsai,项目名称:kingshard,代码行数:11,代码来源:conn_query.go
示例4: executeInNode
func (c *ClientConn) executeInNode(conn *backend.BackendConn, sql string, args []interface{}) ([]*mysql.Result, error) {
var state string
r, err := conn.Execute(sql, args...)
if err != nil {
state = "ERROR"
} else {
state = "INFO"
}
if strings.ToLower(c.proxy.cfg.LogSql) != golog.LogSqlOff {
golog.OutputSql(state, "%s->%s:%s",
c.c.RemoteAddr(),
conn.GetAddr(),
sql,
)
}
if err != nil {
return nil, err
}
return []*mysql.Result{r}, err
}
开发者ID:velsai,项目名称:kingshard,代码行数:22,代码来源:conn_query.go
注:本文中的github.com/flike/kingshard/backend.BackendConn类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论