Method UseDB

backend/direct_connection.go:591–609

UseDB send ComInitDB to backend mysql

(dbName string)

// UseDB send ComInitDB to backend mysql
func (dc *DirectConnection) UseDB(dbName string) error {
	dc.conn.SetSequence(0)
	if dc.db == dbName || len(dbName) == 0 {
		return nil
	}

	if err := dc.writeComInitDB(dbName); err != nil {
		return err
	}

	if r, err := dc.readPacket(); err != nil {
		return err
	} else if !mysql.IsOKPacket(r) {
		return fmt.Errorf("dc connection use db(%s) failed", dbName)
	}

	dc.db = dbName
	return nil
}

// GetDB return database name
func (dc *DirectConnection) GetDB() string {