資料庫操作工具 (cqlsh)

主控畫面

Documented shell commands: =========================== CAPTURE CLS COPY DESCRIBE EXPAND LOGIN SERIAL SOURCE UNICODE CLEAR CONSISTENCY DESC EXIT HELP PAGING SHOW TRACING CQL help topics: ================ AGGREGATES CREATE_KEYSPACE DROP_TRIGGER TEXT ALTER_KEYSPACE CREATE_MATERIALIZED_VIEW DROP_TYPE TIME ALTER_MATERIALIZED_VIEW CREATE_ROLE DROP_USER TIMESTAMP ALTER_TABLE CREATE_TABLE FUNCTIONS TRUNCATE ALTER_TYPE CREATE_TRIGGER GRANT TYPES ALTER_USER CREATE_TYPE INSERT UPDATE APPLY CREATE_USER INSERT_JSON USE ASCII DATE INT UUID BATCH DELETE JSON BEGIN DROP_AGGREGATE KEYWORDS BLOB DROP_COLUMNFAMILY LIST_PERMISSIONS BOOLEAN DROP_FUNCTION LIST_ROLES COUNTER DROP_INDEX LIST_USERS CREATE_AGGREGATE DROP_KEYSPACE PERMISSIONS CREATE_COLUMNFAMILY DROP_MATERIALIZED_VIEW REVOKE CREATE_FUNCTION DROP_ROLE SELECT CREATE_INDEX DROP_TABLE SELECT_JSON

建立資料庫

  1. CREATE KEYSPACE emprogria WITH replication = {'class':'SimpleStrategy', 'replication_factor' : 3};
  2. DESCRIBE keyspaces;

建立資料表格

  1. USE emprogria;
    1. CREATE TABLE stock_history(histid frozen > PRIMARY KEY, quote_open float, quote_close float, quote_high float, quote_low float, quote_vol int);
  2. DESCRIBE stock_history;
    1. CREATE TABLE emprogria.stock_history ( histid frozen> PRIMARY KEY, quote_close float, quote_high float, quote_low float, quote_open float, quote_vol int ) 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',
    2. 'max_threshold': '32', 'min_threshold': '4'} AND compression = {'chunk_length_in_kb': '64',
    3. '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';

新增資料

    1. INSERT INTO emprogria.stock_history(histid, quote_open, quote_close, quote_high, quote_low, quote_vol)
    2. VALUES (('IBM', '2016-10-12'), 150.0, 150.0, 150.0, 150.0, 20000);
  1. SELECT * FROM emprogria.stock_history;
    1. histid | quote_close | quote_high | quote_low | quote_open | quote_vol -----------------------+-------------+------------+-----------+------------+----------- ('IBM', '2016-10-12') | 150 | 150 | 150 | 150 | 20000

更新資料

    1. UPDATE emprogria.stock_history SET quote_open=250.50,quote_close=200.50 WHERE histid=('IBM', '2016-10-12');
  1. SELECT * FROM emprogria.stock_history;
    1. histid | quote_close | quote_high | quote_low | quote_open | quote_vol -----------------------+-------------+------------+-----------+------------+----------- ('IBM', '2016-10-12') | 200.5 | 150 | 150 | 250.5 | 20000

刪除資料

    1. DELETE FROM emprogria.stock_history WHERE histid=('IBM', '2016-10-12');
  1. SELECT * FROM emprogria.stock_history;
    1. histid | quote_close | quote_high | quote_low | quote_open | quote_vol -----------------------+-------------+------------+-----------+------------+----------- (0 rows)