cassandra 数据库中有很多表，其中包含标题为 user_id 的列。值 user_id 是指存储在表 users 中的用户。由于删除了一些用户，我想删除所有包含标题为 user_id 列的表中的孤立记录。
有没有办法使用 CassandraSQLContext 或任何其他内置方法或自定义过程列出所有表，以避免显式定义表列表？
【问题讨论】：
标签： scala apache-spark cassandra spark-cassandra-connector
有一些系统表可以提供有关存储的键空间、表、列的信息。
尝试在 cqlsh 控制台中运行以下命令：
获取键空间信息
SELECT * FROM system.schema_keyspaces ;
获取表格信息
SELECT columnfamily_name FROM system.schema_columnfamilies WHERE keyspace_name = 'keyspace name';
获取表信息
SELECT column_name, type, validator FROM system.schema_columns WHERE keyspace_name = 'keyspace name' AND columnfamily_name = 'table name';
从 v 5.0.x 开始 Docs
获取键空间信息
SELECT * FROM system_schema.keyspaces;
获取表格信息
SELECT * FROM system_schema.tables WHERE keyspace_name = 'keyspace name';
获取表信息
SELECT * FROM system_schema.columns
WHERE keyspace_name = 'keyspace_name' AND table_name = 'table_name';
自 6.0 版起 Docs
获取键空间信息
SELECT * FROM system_schema.keyspaces
获取表格信息
SELECT * FROM system_schema.tables WHERE keyspace_name = 'keyspace name';
获取表信息
SELECT * FROM system_schema.columns
WHERE keyspace_name = 'keyspace_name' AND table_name = 'table_name';
【讨论】：
[cqlsh 5.0.1 | Cassandra 3.11.3 | CQL spec 3.4.4 | Native protocol v4] 版本，获取密钥空间信息适用于 SELECT * FROM system_schema.keyspaces
SELECT * FROM system_schema.tables WHERE keyspace_name = 'keyspace name'
您可以使用 datastax 核心驱动程序和集群元数据来实现您想要的。这是一个示例，它将列出您的键空间中的所有表以及每个表中的列：
Cluster cluster= Cluster.builder().addContactPoint(clusterIp).build();
Metadata metadata =cluster.getMetadata();
Collection<TableMetadata> tablesMetadata= metadata.getKeyspace("mykeyspacename").getTables();
for(TableMetadata tm:tablesMetadata){
System.out.println("Table name:"+tm.getName());
Collection<ColumnMetadata> columnsMetadata=tm.getColumns();
for(ColumnMetadata cm:columnsMetadata){
String columnName=cm.getName();
System.out.println("Column name:"+columnName);
}
}
【讨论】：
从cqlsh执行describe tables;
【讨论】：
use my_keyspace;。
use keyspace_name; 否则您将获得所有键空间的结果。
对于 DSE。如果稍后发布检查 system_schema 键空间。 来自
cqlsh > desc keyspaces;
spark_system system_schema "OpsCenter" cfs_archive "HiveMetaStore"
system_auth cfs demobeta dsefs
dse_security hypermedia dse_leases system_traces dse_perf
solr_admin system system_distributed dse_system
如果您看到“system_schema”，则表的元数据位于此键空间中。
cqlsh>use system_schema;
cqlsh>select keyspace_name,table_name from tables where keyspace_name = 'system';
【讨论】：
system 键空间不是 DSE 特定的 - 它是 Cassandra 的核心功能...... Cassandra 版本之间的模式表示不同，因此最好的方法是使用 cqlsh 的 @ 987654326@，或通过@zoran jeremic 指出的元数据访问
dse 前缀，例如dse_security、dse_leases 等（尽管cfs 和solr_admin 不遵循此约定）。总体而言，如果您需要以编程方式访问这些数据，那么最好使用支持 Metadata 的驱动程序 - 它与版本无关。
列出所有表（仅表名），
DESC tables;
列出所有表和模式（CQL 创建语句），
DESC {$KEYSPACE_NAME} 而{$KEYSPACE_NAME} 是键空间的名称。
我使用的是从官网下载的Apache Cassandra 3.11.4二进制包：
cql> show version;
[cqlsh 5.0.1 | Cassandra 3.11.4 | CQL spec 3.4.4 | Native protocol v4]
Apache Cassandra 的 CQL 参考在这里：https://cassandra.apache.org/doc/cql3/CQL-3.0.html
【讨论】：
尝试运行以下查询：
cqlsh> describe keyspace <keyspace_name>;
【讨论】：
只需连接 CQLSH 并尝试以下命令
描述表格；或
DESC 架构；
您还可以“描述键空间；”和“使用键空间；”您想在哪里查看带有“描述表格”的表格；
【讨论】：
cqlsh 命令...
desc keyspaces; // list all databases/collections names
use anyKeyspace; // select any database
desc tables; // list all tables in collection/ database
【讨论】：