В этом примере показано, как исследовать структуру базы данных Apache Cassandra® и импортировать данные от таблицы базы данных Кассандры в MATLAB® с помощью соединения с базой данных Кассандры с Apache база данных Кассандры интерфейс C++. База данных Кассандры хранит таблицы базы данных согласно ключу раздела. Ключ раздела влияет, как данные отфильтрованы в базе данных.
В этом примере база данных Кассандры содержит employees_by_job таблица базы данных с данными сотрудника и job_id ключ раздела.
Создайте соединение с базой данных Кассандры с помощью сконфигурированного источника данных CassandraDataSource и пустое имя пользователя и пароль. apacheCassandra функция возвращает conn как connection объект.
datasource = "CassandraDataSource"; username = ""; password = ""; conn = apacheCassandra(datasource,username,password);
Просмотрите ключевые пространства в базе данных Кассандры с помощью соединения с базой данных Кассандры. Массив возвращаемой строки содержит ключевые пространства. Ключевое пространство содержит одну или несколько таблиц базы данных и задает, как база данных реплицирует данные в таблицы.
conn.Keyspaces
ans = 6×1 string
"employeedata"
"system"
"system_auth"
"system_distributed"
"system_schema"
"system_traces"
Возвратите имена таблиц базы данных Кассандры в employeedata ключевое пространство. t массив строк, который содержит имена таблиц базы данных в employeedata ключевое пространство.
keyspace = "employeedata";
t = tablenames(conn,keyspace)t = 3×1 string
"employees_by_id"
"employees_by_job"
"employees_by_name"
Возвратите имена столбцов базы данных Кассандры в employees_by_job таблица базы данных.
tablename = "employees_by_job";
cols = columninfo(conn,keyspace,tablename);Отобразите первые несколько имен столбцов базы данных Кассандры в employees_by_job таблица базы данных.
head(cols)
ans=8×4 table
Name DataType PartitionKey ClusteringColumn
________________ ________ ____________ ________________
"job_id" "text" true ""
"hire_date" "date" false "DESC"
"employee_id" "int" false "ASC"
"commission_pct" "double" false ""
"department_id" "int" false ""
"email" "text" false ""
"first_name" "text" false ""
"last_name" "text" false ""
cols таблица с этими переменными:
Name — Имя столбца базы данных Кассандры
DataType — Тип данных Языка запросов Кассандры (CQL) столбца базы данных Кассандры
PartitionKey — Ключевой показатель раздела
ClusteringColumn — Кластеризация индикатора столбца
Значение в PartitionKey переменная указывает, является ли столбец базы данных ключом раздела. Столбец job_id (идентификатор задания), ключ раздела в этой таблице базы данных.
Импортируйте данные от employees_by_job таблица базы данных в MATLAB. Эта база данных имеет данные о клерках магазина, так используйте значение ключа раздела SH_CLERK.
keyValue = "SH_CLERK"; results = partitionRead(conn,keyspace,tablename, ... keyValue);
Отобразите первые несколько строк возвращенных данных сотрудника.
head(results)
ans=8×13 table
job_id hire_date employee_id commission_pct department_id email first_name last_name manager_id office performance_ratings phone_number salary
building room
__________ ___________ ___________ ______________ _____________ __________ __________ __________ __________ ________________ ___________________ ______________ ______
"SH_CLERK" 03-Feb-2008 183 NaN 50 "GGEONI" "Girard" "Geoni" 120 "West" 121 {[ 2]} "650.507.9879" 2800
"SH_CLERK" 13-Jan-2008 199 NaN 50 "DGRANT" "Douglas" "Grant" 124 "West" 139 {3×1 int32} "650.507.9844" 2600
"SH_CLERK" 19-Dec-2007 191 NaN 50 "RPERKINS" "Randall" "Perkins" 122 "West" 255 {[ 2]} "650.505.4876" 2500
"SH_CLERK" 21-Jun-2007 182 NaN 50 "MSULLIVA" "Martha" "Sullivan" 120 "East" 112 {2×1 int32} "650.507.9878" 2500
"SH_CLERK" 21-Jun-2007 198 NaN 50 "DOCONNEL" "Donald" "OConnell" 124 "East" 125 {3×1 int32} "650.507.9833" 2600
"SH_CLERK" 17-Mar-2007 195 NaN 50 "VJONES" "Vance" "Jones" 123 "West" 236 {5×1 int32} "650.501.4876" 2800
"SH_CLERK" 07-Feb-2007 187 NaN 50 "ACABRIO" "Anthony" "Cabrio" 121 "West" 345 {3×1 int32} "650.509.4876" 3000
"SH_CLERK" 11-Jul-2006 190 NaN 50 "TGATES" "Timothy" "Gates" 122 "East" 297 {3×1 int32} "650.505.3876" 2900
results таблица, которая содержит эти переменные:
job_id — Идентификатор задания
hire_date — Наймите дату
employee_id — Идентификатор сотрудника
commission_pct — Уполномочьте процент
department_id — Идентификатор отдела
email — Адрес электронной почты
first_name — Имя
last_name — Фамилия
manager_id — Идентификатор менеджера
office — Местоположение Office (таблица, которая содержит две переменные для создания и комнаты),
performance_ratings — Оценки эффективности
phone_number — Номер телефона
salary — Зарплата
close(conn)
apacheCassandra | tablenames | columninfo | partitionRead | close