CODEWITHSUNDEEP
cassandranosqlcqlcql3cqlsh
madcrazydrumma
madcrazydrumma

Reputation: 1897

Unmatched column names/values when inserting data in Cassandra cqlsh

So I am using the current query to insert data into my column family:

INSERT INTO airports (apid, name, iata, icao, x, y, elevation, code, name, oa_code, dst, cid, name, timezone, tz_id) VALUES (12012,'Ararat Airport','ARY','YARA','142.98899841308594','-37.30939865112305',1008,{ code: 'AS', name: 'Australia', oa_code: 'AU', dst: 'U',city: { cid: 1, name: '', timezone: '', tz_id: ''}});

Now, I'm getting the error: Unmatched column names/values when this is my current model for the airports columnfamily:

CREATE TYPE movielens.cityudt (
    cid varint,
    name text,
    timezone varint,
    tz_id text
);

CREATE TYPE movielens.countryudt (
    code text,
    name text,
    oa_code text,
    dst text,
    city frozen<cityudt>
);

CREATE TABLE movielens.airports (
    apid varint PRIMARY KEY,
    country frozen<countryudt>,
    elevation varint,
    iata text,
    icao text,
    name text,
    x varint,
    y varint
) WITH bloom_filter_fp_chance = 0.01
    AND caching = {'keys': 'ALL', 'rows_per_partition': 'NONE'}
    AND comment = ''
    AND compaction = {'class': 'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy', 'max_threshold': '32', 'min_threshold': '4'}
    AND compression = {'chunk_length_in_kb': '64', 'class': 'org.apache.cassandra.io.compress.LZ4Compressor'}
    AND crc_check_chance = 1.0
    AND dclocal_read_repair_chance = 0.1
    AND default_time_to_live = 0
    AND gc_grace_seconds = 864000
    AND max_index_interval = 2048
    AND memtable_flush_period_in_ms = 0
    AND min_index_interval = 128
    AND read_repair_chance = 0.0
    AND speculative_retry = '99PERCENTILE';

But I cant see the problem with the insert! Can someone help me figure out where I am going wrong?

Upvotes: 1

Views: 1505

Answers (2)

Aaron
Aaron

Reputation: 57748

Ok, so I did manage to get this work after adjusting your x and y columns to doubles:

INSERT INTO airports (apid, name, iata, icao, x, y, elevation, country)
VALUES (12012,'Ararat Airport','ARY','YARA',142.98899841308594,-37.30939865112305,
        1008,{ code: 'AS', name: 'Australia', oa_code: 'AU', dst: 'U', 
            city:{ cid: 1, name: '', timezone: 0, tz_id: ''}});

cassdba@cqlsh:stackoverflow> SELECT * FROM airports WHERE apid=12012;

 apid  | country                                                                                                    | elevation | iata | icao | name           | x       | y
-------+------------------------------------------------------------------------------------------------------------+-----------+------+------+----------------+---------+----------
 12012 | {code: 'AS', name: 'Australia', oa_code: 'AU', dst: 'U', city: {cid: 1, name: '', timezone: 0, tz_id: ''}} |      1008 |  ARY | YARA | Ararat Airport | 142.989 | -37.3094

(1 rows)

Remember that VARINTs don't take single quotes (like timezone).

Also, you were specifying each type's column, when you just needed to specify country in your column list (as you mentioned).

Upvotes: 2

madcrazydrumma
madcrazydrumma

Reputation: 1897

When inserting into a frozen udt, you do not have to specify the insert for all the rows (even those inside the frozen udt), therefore to fix the query I had to remove all those up to the elevation column and add country.

Upvotes: 0

Related Questions