connection

Соединение с базой данных Apache Cassandra

Описание

The connection объект представляет Apache Cassandra® подключение к базе данных, созданное с помощью интерфейса C++ базы данных Apache Cassandra.

После создания connection объект, можно использовать функции объекта для импорта данных из базы данных Cassandra в MATLAB®. Также можно экспортировать данные из MATLAB в базу данных Cassandra. Можно также исследовать структуру базы данных и выполнять запросы Cassandra Query Language (CQL).

Для получения дополнительной информации о базе данных Cassandra смотрите документацию Apache Cassandra.

Создание

Создайте connection объект при помощи apacheCassandra функция.

Свойства

расширить все

Это свойство доступно только для чтения.

Имя кластера Кассандры, заданное как строковый скаляр.

Пример: "Test Cluster"

Типы данных: string

Это свойство доступно только для чтения.

Адрес хоста для одного узла или адреса хоста для нескольких узлов в кластере Cassandra, заданный как строковый скаляр для одного узла или строковые массивы для нескольких узлов. Эти адреса включают адреса, указанные в 'ContactPoints' имя-значение аргумента apacheCassandra функция.

Пример: "localhost/127.0.0.1"

Типы данных: string

Это свойство доступно только для чтения.

Имя локального центра обработки данных, заданное как строковый скаляр. Имя описывает центр обработки данных, который кластер объявляет локальным для образца соединения. Имя соответствует центру данных исходной точки контакта для подключения. При настройке кластера определяется центр обработки данных для каждого узла.

Пример: "datacenter1"

Типы данных: string

Это свойство доступно только для чтения.

Пространства ключей в базе данных Cassandra, заданные как строковый скаляр или строковые массивы. Строковый скаляр указывает, что база данных Cassandra имеет один ключевой пространство, а строковые массивы указывают несколько ключевых пространств.

Пример: ["employeedata" "system"]

Типы данных: string

Это свойство доступно только для чтения.

Тайм-аут запроса, заданный как положительный числовой скаляр. Тайм-аут запроса указывает количество секунд, в течение которых база данных ожидает возврата запроса CQL перед выдачей ошибки.

Типы данных: double

Функции объекта

расширить все

closeЗакройте соединение с базой данных Apache Cassandra
isopenОпределите, открыто ли соединение с базой данных Apache Cassandra
columninfoПолучение сведений о столбцах из таблицы базы данных Apache Cassandra
partitionReadИмпорт данных из разделов таблицы базы данных Apache Cassandra
tablenamesСписок имен таблиц базы данных в базе данных Apache Cassandra
upsertВставка или обновление данных в базу данных Apache Cassandra
executecqlВыполните запрос CQL в базе данных Apache Cassandra

Примеры

свернуть все

Создайте подключение базы данных к базе данных Apache Cassandra ® с помощью интерфейса C++ базы данных Apache Cassandra. Чтобы создать это подключение, необходимо сконфигурировать источник данных Cassandra. Для получения дополнительной информации смотрите databaseConnectionOptions функция. Используя локальный адрес хоста, создайте соединение с базой данных и отобразите ключевые пространства в базе данных.

Создайте соединение с базой данных Cassandra с помощью настроенного источника данных CassandraDataSource и пустые имя пользователя и пароль.

datasource = "CassandraDataSource";
username = "";
password = "";
conn = apacheCassandra(datasource,username,password)
conn = 
  connection with properties:

            Cluster: "Test Cluster"
      HostAddresses: "127.0.0.1"
    LocalDataCenter: "datacenter1"
     RequestTimeout: 20
          Keyspaces: [6×1 string]

conn является connection объект, который содержит следующие свойства:

  • Имя кластера Кассандра

  • Адрес хоста

  • Имя локального центра обработки данных

  • Keyspaces

  • Тайм-аут запроса

Отобразите ключевые пространства в базе данных Cassandra путем доступа к Keyspaces свойство connection объект.

conn.Keyspaces
ans = 6×1 string
    "employeedata"
    "system"
    "system_auth"
    "system_distributed"
    "system_schema"
    "system_traces"

Закройте соединение с базой данных Cassandra.

close(conn)
Введенный в R2021a