Method getStatementTag

pgserver/duck_handler.go:287–310

(mysqlConn *mysql.Conn, query string)

		params := make([]any, len(paramTypes)) // all nil
		rows, err = execer.QueryContext(sqlCtx, query, params...)
		if err != nil {
			break
		}
		defer rows.Close()
		schema, err := pgtypes.InferSchema(rows)
		if err != nil {
			break
		}
		fields = schemaToFieldDescriptions(sqlCtx, schema, nil, ExtendedQueryMode)
	default:
		// For other statements, we just return the "affected rows" field.
		fields = []pgproto3.FieldDescription{
			{
				Name:         []byte("Rows"),
				DataTypeOID:  pgtype.Int4OID,
				DataTypeSize: 4,
			},
		}
	}
	if err != nil {
		return nil, nil, nil, err
	}

	return nil, paramOIDs, fields, nil
}

// ComQuery implements the Handler interface.