Flutter Cassandra数据库连接插件cassandart的使用

本文将详细介绍如何在Flutter项目中使用cassandart插件来连接和操作Cassandra数据库。cassandart是一个用于Dart语言的Cassandra客户端库，支持基本的数据类型，并且能够自动检测和连接到性能最佳的节点。

功能简介

• 该插件可以与Cassandra（包括Elassandra）一起使用。
• 它能够处理基本的数据类型（目前不支持map类型）。
• 自动检测并连接到Cassandra集群中的节点。
• 根据延迟自动选择最佳节点。
• 使用hint来选择最有可能包含数据的节点。

注意：这是一个实验性的库和协议，请谨慎使用。

如何贡献

在提交PR之前，请先检查并遵循Cassandra的v4版本的线协议规范。

示例代码

以下是一个完整的示例代码，展示了如何使用cassandart插件来创建一个Cassandra表、插入数据并进行查询。

import 'dart:convert';

import 'package:cassandart/cassandart.dart';
import 'package:http/http.dart' as http;

void main() async {
  // 创建HTTP客户端
  final hc = http.Client();

  // 连接到Cassandra集群
  final client = await Cluster.connect(
    ['localhost:9042'], // Cassandra集群地址
    authenticator: PasswordAuthenticator('cassandra', 'cassandra'), // 认证信息
  );

  // 创建Keyspace
  await client.execute('CREATE KEYSPACE IF NOT EXISTS foo '
      'WITH REPLICATION = { '
      "'class' : 'NetworkTopologyStrategy', 'DC1' : 2 }");

  // 创建表
  await client.execute(
      'CREATE TABLE IF NOT EXISTS foo.tbl (id text PRIMARY KEY, content TEXT, category TEXT, rankz INT)');

  // 插入数据
  await client.execute(
    'INSERT INTO foo.tbl (id, content, category, rankz) VALUES (:id, :content, :category, :rankz)',
    values: {
      'id': 'cake',
      'category': 'food',
      'rankz': Value.int32(1202),
      'content':
          'Cake is a form of sweet food made from flour, sugar, and other ingredients, that is usually baked.',
    },
    consistency: Consistency.one,
  );

  await client.execute(
    'INSERT INTO foo.tbl (id, content, category, rankz) VALUES (:id, :content, :category, :rankz)',
    values: {
      'id': 'soup',
      'category': 'food',
      'rankz': Value.int32(2011),
      'content':
          'Soup is a primarily liquid food, generally served warm or hot (but may be cool or cold), '
              'that is made by combining ingredients of meat or vegetables with stock, or water. It is not baked.',
    },
    consistency: Consistency.one,
  );

  // 创建Elasticsearch索引
  final rscreate = await hc.put(
    Uri.parse('http://localhost:9200/foo'),
    headers: {
      'content-type': 'application/json',
    },
    body: json.encode({
      'settings': {
        'index': {
          'sort.field': 'rankz',
          'sort.order': 'desc',
          'analysis': {
            'filter': {},
            'analyzer': {
              'ngram_analyzer': {
                'filter': ['lowercase'],
                'tokenizer': 'ngram_tokenizer'
              },
            },
            'tokenizer': {
              'ngram_tokenizer': {
                'type': 'ngram',
                'min_gram': 2,
                'max_gram': 3,
              }
            }
          }
        }
      },
      'mappings': {
        'tbl': {
          // 'discover': '.*',
          'properties': {
            'rankz': {
              'type': 'integer',
              'cql_collection': 'singleton',
            },
            'content': {
              'type': 'text',
              'cql_collection': 'singleton',
              'fields': {
                'keyword': {'type': 'keyword'},
                'ngram': {
                  'type': 'text',
                  'analyzer': 'ngram_analyzer',
//                  'search_analyzer': 'edge_ngram_search_analyzer'
                }
              }
            },
          },
        },
      },
    }),
  );
  print(rscreate.body);

  // 等待1秒
  await Future.delayed(Duration(seconds: 1));

  // 查询Elasticsearch
  final rs =
      await hc.get(Uri.parse('http://localhost:9200/foo/_search?pretty'));
  print(rs.body);

  // 关闭Cassandra客户端
  await client.close();
  // 关闭HTTP客户端
  hc.close();
}

代码解释

1. 导入依赖

   import 'dart:convert';
   import 'package:cassandart/cassandart.dart';
   import 'package:http/http.dart' as http;
   

2. 创建HTTP客户端

   final hc = http.Client();
   

3. 连接到Cassandra集群

   final client = await Cluster.connect(
     ['localhost:9042'],
     authenticator: PasswordAuthenticator('cassandra', 'cassandra'),
   );
   

4. 创建Keyspace

   await client.execute('CREATE KEYSPACE IF NOT EXISTS foo '
       'WITH REPLICATION = { '
       "'class' : 'NetworkTopologyStrategy', 'DC1' : 2 }");
   

5. 创建表

   await client.execute(
       'CREATE TABLE IF NOT EXISTS foo.tbl (id text PRIMARY KEY, content TEXT, category TEXT, rankz INT)');
   

6. 插入数据

   await client.execute(
     'INSERT INTO foo.tbl (id, content, category, rankz) VALUES (:id, :content, :category, :rankz)',
     values: {
       'id': 'cake',
       'category': 'food',
       'rankz': Value.int32(1202),
       'content':
           'Cake is a form of sweet food made from flour, sugar, and other ingredients, that is usually baked.',
     },
     consistency: Consistency.one,
   );
   

7. 创建Elasticsearch索引

   final rscreate = await hc.put(
     Uri.parse('http://localhost:9200/foo'),
     headers: {
       'content-type': 'application/json',
     },
     body: json.encode({
       'settings': {
         'index': {
           'sort.field': 'rankz',
           'sort.order': 'desc',
           'analysis': {
             'filter': {},
             'analyzer': {
               'ngram_analyzer': {
                 'filter': ['lowercase'],
                 'tokenizer': 'ngram_tokenizer'
               },
             },
             'tokenizer': {
               'ngram_tokenizer': {
                 'type': 'ngram',
                 'min_gram': 2,
                 'max_gram': 3,
               }
             }
           }
         }
       },
       'mappings': {
         'tbl': {
           'properties': {
             'rankz': {
               'type': 'integer',
               'cql_collection': 'singleton',
             },
             'content': {
               'type': 'text',
               'cql_collection': 'singleton',
               'fields': {
                 'keyword': {'type': 'keyword'},
                 'ngram': {
                   'type': 'text',
                   'analyzer': 'ngram_analyzer',
                 }
               }
             },
           },
         },
       },
     }),
   );
   print(rscreate.body);
   

8. 查询Elasticsearch

   final rs =
       await hc.get(Uri.parse('http://localhost:9200/foo/_search?pretty'));
   print(rs.body);
   

9. 关闭客户端

   await client.close();
   hc.close();