Method HandleFieldList

cmd/cql-mysql-adapter/cursor.go:342–406

HandleFieldList handle COM_FILED_LIST command.

(table string, fieldWildcard string)

// HandleFieldList handle COM_FILED_LIST command.
func (c *Cursor) HandleFieldList(table string, fieldWildcard string) (fields []*my.Field, err error) {
	var conn *sql.DB

	if conn, err = c.ensureDatabase(); err != nil {
		return
	}

	// send show tables command
	var columns *sql.Rows
	if columns, err = conn.Query(fmt.Sprintf("DESC `%s`", table)); err != nil {
		// wrap error
		err = my.NewError(my.ER_UNKNOWN_ERROR, err.Error())
		return
	}

	defer columns.Close()

	// transform the sql wildcard to glob pattern
	var fieldGlob string

	if fieldWildcard != "" {
		fieldGlob = strings.NewReplacer("_", "?", "%", "*").Replace(fieldWildcard)
	}

	var cid, defaultValue interface{}
	var columnName, typeString string
	var isNotNull, isPK bool

	for columns.Next() {
		if err = columns.Scan(&cid, &columnName, &typeString, &isNotNull, &defaultValue, &isPK); err != nil {
			return
		}

		if fieldGlob != "" {
			if matched, _ := filepath.Match(fieldGlob, columnName); !matched {
				continue
			}
		}

		// process flag
		colFlag := uint16(0)

		if isNotNull {
			colFlag |= my.NOT_NULL_FLAG
		}
		if isPK {
			colFlag |= my.NOT_NULL_FLAG
			colFlag |= my.PRI_KEY_FLAG
		}

		fields = append(fields, &my.Field{
			Name:         []byte(columnName),
			OrgName:      []byte(columnName),
			Table:        []byte(table),
			OrgTable:     []byte(table),
			Schema:       []byte(c.curDB),
			Flag:         colFlag,
			Charset:      uint16(my.DEFAULT_COLLATION_ID),