Method WriteSetStatement

backend/direct_connection.go:761–789

WriteSetStatement execute sql

()

// WriteSetStatement execute sql
func (dc *DirectConnection) WriteSetStatement() error {
	var setVariableSQL bytes.Buffer
	collation, ok := mysql.Collations[dc.collation]
	if !ok {
		return fmt.Errorf("invalid collationId: %v", dc.collation)
	}
	appendSetCharset(&setVariableSQL, dc.charset, collation)

	for _, v := range dc.sessionVariables.GetAll() {
		if v.Name() == mysql.TxReadOnly && dc.versionCompare != nil && !dc.versionCompare.LessThanMySQLVersion803 {
			appendSetVariable(&setVariableSQL, mysql.TransactionReadOnly, v.Get())
			continue
		}
		appendSetVariable(&setVariableSQL, v.Name(), v.Get())
	}

	for _, v := range dc.sessionVariables.GetUnusedAndClear() {
		appendSetVariableToDefault(&setVariableSQL, v.Name())
	}

	setSQL := setVariableSQL.String()
	if setSQL == "" {
		return nil
	}
	if _, err := dc.exec(setSQL, 0); err != nil {
		return err
	}
	return nil
}

// FieldList send ComFieldList to backend mysql
func (dc *DirectConnection) FieldList(table string, wildcard string) ([]*mysql.Field, error) {