全部產品
Search
文件中心

Lindorm:通過Cassandra CQL非Java Driver的應用開發

更新時間:Jul 06, 2024

本文介紹多語言Driver(例如C++、Python、Nodejs和Go)通過Cassandra CQL訪問Lindorm寬表引擎的操作方法。

前提條件

  • 已擷取Lindorm寬表引擎的CQL串連地址,具體如下圖所示。CQL串連地址

  • 根據您使用的語言下載並安裝驅動程式。更多資訊請參見Cassandra client drivers

Cassandra CQL Python Driver訪問Lindorm寬表

  1. 安裝Datastax Python依賴包,具體操作請參見安裝Python SDK

    # 指定版本安裝(建議安裝3.x版本)
    pip install cassandra-driver==3.19.0
    # 安裝最新版本
    pip install cassandra-driver
  2. 訪問Lindorm寬表的範例程式碼。

    #!/usr/bin/env python
    # -*- coding: UTF-8 -*-
    import logging
    import sys
    from cassandra.cluster import Cluster
    from cassandra.auth import PlainTextAuthProvider
    
    logging.basicConfig(stream=sys.stdout, level=logging.INFO)
    
    cluster = Cluster(
        # 填寫Lindorm寬表引擎的CQL串連地址,不用填連接埠
        contact_points=["ld-bp17j28j2y7pm****-proxy-lindorm.lindorm.rds.aliyuncs.com"],
        # 填寫使用者名稱和密碼,預設為root
        auth_provider=PlainTextAuthProvider("cassandra", "****"))
    
    session = cluster.connect()
    # 建立keyspace
    session.execute(
                    "CREATE KEYSPACE IF NOT EXISTS testKeyspace WITH replication = {'class':'SimpleStrategy', 'replication_factor':1};");
    
    # 建立table
    session.execute(
                    "CREATE TABLE IF NOT EXISTS testKeyspace.testTable (id int PRIMARY KEY, name text,age int,address text);");
    
    # 插入資料
    session.execute(
                    "INSERT INTO testKeyspace.testTable (id, name, age, address) VALUES ( 1, 'testname', 11, 'hangzhou');");
    
    # 查詢資料
    rows = session.execute(
                    "SELECT * FROM testKeyspace.testTable ;");
    
    # 列印每行資料到控制台
    for row in rows:
        print("# row: {}".format(row))
    
    # 關閉Session
    session.shutdown()
    
    # 關閉
    cluster.shutdown()

Cassandra CQL C++ Driver訪問Lindorm寬表

  1. 下載C++依賴包,下載連結請參見Datastax c++

  2. 訪問Lindorm寬表的範例程式碼。

    CassFuture* connect_future = NULL;
    CassCluster* cluster = cass_cluster_new();
    CassSession* session = cass_session_new();
    //填寫Lindorm寬表引擎的CQL串連地址,不用填連接埠
    char* hosts = "ld-bp17j28j2y7pm****-proxy-lindorm.lindorm.rds.aliyuncs.com";
    
    //建立串連
    cass_cluster_set_contact_points(cluster, hosts);
    connect_future = cass_session_connect(session, cluster);
    
    //DDL操作
    if (cass_future_error_code(connect_future) == CASS_OK) {
        CassFuture* close_future = NULL;
    
        
        const char* query = "SELECT  name FROM testKeyspace.testTable ";
        CassStatement* statement = cass_statement_new(query, 0);
    
        CassFuture* result_future = cass_session_execute(session, statement);
    
        if (cass_future_error_code(result_future) == CASS_OK) {
          //擷取查詢結果
          const CassResult* result = cass_future_get_result(result_future);
          const CassRow* row = cass_result_first_row(result);
    
          if (row) {
            const CassValue* value = cass_row_get_column_by_name(row, "name");
            //列印結果
            const char* name;
            size_t name_length;
            cass_value_get_string(value, &name, &name_length);
            printf("release_version: '%.*s'\n", (int)name_length, name);
          }
    
          cass_result_free(result);
        } else {
          //異常處理
          const char* message;
          size_t message_length;
          cass_future_error_message(result_future, &message, &message_length);
          fprintf(stderr, "Unable to run query: '%.*s'\n", (int)message_length, message);
        }
    
        cass_statement_free(statement);
        cass_future_free(result_future);
    
        //手動釋放資源資訊
        close_future = cass_session_close(session);
        cass_future_wait(close_future);
        cass_future_free(close_future);
      } else {
        //異常處理
        const char* message;
        size_t message_length;
        cass_future_error_message(connect_future, &message, &message_length);
        fprintf(stderr, "Unable to connect: '%.*s'\n", (int)message_length, message);
      }
    
      cass_future_free(connect_future);
      cass_cluster_free(cluster);
      cass_session_free(session);           

Cassandra CQL Nodejs Driver訪問Lindorm寬表

  1. 安裝Node.js依賴包。

    npm install cassandra-driver 
  2. 訪問Lindorm寬表的範例程式碼。

    const cassandra = require('cassandra-driver');
    
    /**
    * 填寫Lindorm寬表引擎的CQL串連地址,不用填連接埠。dc名字填datacenter1
    * 填寫使用者名稱和密碼,預設為root
    */
    const client = new cassandra.Client({ contactPoints: ['ld-bp17j28j2y7pm****-proxy-lindorm.lindorm.rds.aliyuncs.com'], localDataCenter: 'datacenter1', credentials: { username: '使用者名稱', password: '密碼' } });
    
    client.connect()
    .then(() => client.execute("CREATE KEYSPACE IF NOT EXISTS lindormtest WITH replication = {'class': 'SimpleStrategy', 'replication_factor': '2' }"))
    .then(() => client.execute("CREATE TABLE IF NOT EXISTS lindormtest.nodejs (name text PRIMARY KEY, age int)"))
    .then(() => {
     return client.execute("INSERT INTO lindormtest.nodejs (name, age) VALUES ('lindorm', 10)");
    })
    .then(() => {
     return client.execute("SELECT name, age FROM lindormtest.nodejs WHERE name = 'lindorm' ");
    })
    .then(result => {
     const row = result.first();
     console.log('Obtained row: ', row);
     const p = row.age;
    })
    .finally(() => client.shutdown());
                

Cassandra CQL go Driver訪問Lindorm寬表

  1. 安裝GoCQL。

    go get github.com/gocql/gocql
  2. 訪問Lindorm寬表的範例程式碼。

    package main
    
    import (
        "fmt"
        "log"
    
        "github.com/gocql/gocql"
    )
    
    func main() {
        // 填寫Lindorm寬表引擎的CQL串連地址,不用填連接埠
        cluster := gocql.NewCluster("ld-bp17j28j2y7pm****-proxy-lindorm.lindorm.rds.aliyuncs.com")
        cluster.Authenticator = gocql.PasswordAuthenticator{
            Username:"使用者名稱",
            Password: "密碼",
        }
    
        session, _ := cluster.CreateSession()
        defer session.Close()
    
        //create keyspace
        if err := session.Query(`CREATE KEYSPACE ks WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 2}`).Exec(); err != nil {
            log.Fatal(err)
        }
    
        // create table
        if err := session.Query(`CREATE TABLE ks.tb (cn1 text PRIMARY KEY, cn2 text, cn3 text)`).Exec(); err != nil {
            log.Fatal(err)
        }
    
        // insert value
        if err := session.Query(`INSERT INTO ks.tb (cn1, cn2, cn3) VALUES (?, ?, ?)`,
            "v11", "v12", "v13").Exec(); err != nil {
            log.Fatal(err)
        }
    
        var column1 string
        var column2 string
    
        if err := session.Query(`SELECT cn1, cn2 FROM ks.tb WHERE cn1 = ?`,
            "v11").Consistency(gocql.One).Scan(&column1, &column2); err != nil {
            log.Fatal(err)
        }
        fmt.Println("ALL values:", column1, column2)
    
        var column3 string
        // list all tweets
        iter := session.Query(`SELECT * FROM ks.tb WHERE cn1 = ? `, "v11").Iter()
        for iter.Scan(&column1, &column2, &column3) {
            fmt.Println("ALL value:", column1, column2, column3)
        }
        if err := iter.Close(); err != nil {
            log.Fatal(err)
        }
    }