Method popConn

IceFireDB-SQLProxy/internal/mysql/proxy.go:126–161

(pool *client.Pool)

}

func (m *mysqlProxy) popConn(pool *client.Pool) (*client.Conn, error) {
	var mysqlConn *client.Conn
	var err error
	for i := 0; i < GetConnRetry; i++ {
		mysqlConn, err = pool.GetConn(m.ctx)
		if err != nil {
			continue
		}
		err = mysqlConn.Ping()
		if err != nil {
			continue
		}

		if mysqlConn.IsInTransaction() {
			if err := mysqlConn.Rollback(); err != nil {
				mysqlConn.Close()
				continue
			}
		}
		if !mysqlConn.IsAutoCommit() {
			if err := mysqlConn.SetAutoCommit(true); err != nil {
				mysqlConn.Close()
				continue
			}
		}

		if mysqlConn.GetCharset() != mysql.DEFAULT_CHARSET {
			if err := mysqlConn.SetCharset(mysql.DEFAULT_CHARSET); err != nil {
				mysqlConn.Close()
				continue
			}
		}
		break
	}
	return mysqlConn, nil
}

func (m *mysqlProxy) pushAdminConn(mysqlConn *client.Conn, err error) {
	m.pushConn(mysqlConn, err, m.adminPool)