import "gopkg.in/src-d/go-vitess.v1/vt/mysqlproxy"
Package mysqlproxy is a basic module that proxies a mysql server session to appropriate calls in a queryservice back end, with optional query normalization.
type Proxy struct {
// contains filtered or unexported fields
}
Proxy wraps the standalone query service
func NewProxy(target *querypb.Target, qs queryservice.QueryService, normalize bool) *Proxy
NewProxy creates a new proxy
func (mp *Proxy) Execute(ctx context.Context, session *ProxySession, sql string, bindVariables map[string]*querypb.BindVariable) (*ProxySession, *sqltypes.Result, error)
Execute runs the given sql query in the specified session
Rollback rolls back the session
type ProxySession struct { TransactionID int64 TargetString string Options *querypb.ExecuteOptions Autocommit bool }
ProxySession holds session state for the proxy
Package mysqlproxy imports 7 packages (graph) and is imported by 2 packages. Updated 2019-06-13. Refresh now. Tools for package owners.