Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <dependency>
- <groupId>com.datastax.cassandra</groupId>
- <artifactId>cassandra-driver-core</artifactId>
- <version>2.1.9</version>
- </dependency>
- <dependency>
- <groupId>com.datastax.cassandra</groupId>
- <artifactId>dse-driver</artifactId>
- <version>1.1.2</version>
- </dependency>
- # old driver
- mvn -Pcassandra-driver clean package
- java -jar target/cassandra-print-column-metadata-cassandra-driver.jar <address> <user> <password> <keyspace> <table>
- ...
- ts timestamp
- ...
- # new driver
- mvn -Pdse-driver clean package
- java -jar target/cassandra-print-column-metadata-dse-driver.jar <address> <user> <password> <keyspace> <table>
- ...
- ts 'org.apache.cassandra.db.marshal.DateType'
- ...
- <?xml version="1.0" encoding="UTF-8" standalone="no"?>
- <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
- <modelVersion>4.0.0</modelVersion>
- <groupId>cnauroth</groupId>
- <artifactId>cassandra-print-column-metadata</artifactId>
- <version>0.0.1-SNAPSHOT</version>
- <description>Console application that prints Cassandra table column metadata</description>
- <name>cassandra-print-column-metadata</name>
- <packaging>jar</packaging>
- <properties>
- <maven.compiler.source>1.7</maven.compiler.source>
- <maven.compiler.target>1.7</maven.compiler.target>
- <slf4j.version>1.7.25</slf4j.version>
- </properties>
- <build>
- <plugins>
- <plugin>
- <artifactId>maven-assembly-plugin</artifactId>
- <configuration>
- <archive>
- <manifest>
- <addDefaultImplementationEntries>true</addDefaultImplementationEntries>
- <mainClass>cnauroth.Main</mainClass>
- </manifest>
- </archive>
- <descriptorRefs>
- <descriptorRef>jar-with-dependencies</descriptorRef>
- </descriptorRefs>
- <finalName>${project.artifactId}</finalName>
- <appendAssemblyId>false</appendAssemblyId>
- </configuration>
- <executions>
- <execution>
- <id>make-assembly</id>
- <phase>package</phase>
- <goals>
- <goal>single</goal>
- </goals>
- </execution>
- </executions>
- </plugin>
- </plugins>
- </build>
- <profiles>
- <profile>
- <id>dse-driver</id>
- <activation>
- <activeByDefault>true</activeByDefault>
- </activation>
- <dependencies>
- <dependency>
- <groupId>com.datastax.cassandra</groupId>
- <artifactId>dse-driver</artifactId>
- <version>1.1.2</version>
- </dependency>
- </dependencies>
- <build>
- <plugins>
- <plugin>
- <artifactId>maven-assembly-plugin</artifactId>
- <configuration>
- <finalName>${project.artifactId}-dse-driver</finalName>
- </configuration>
- </plugin>
- </plugins>
- </build>
- </profile>
- <profile>
- <id>cassandra-driver</id>
- <activation>
- <activeByDefault>false</activeByDefault>
- </activation>
- <dependencies>
- <dependency>
- <groupId>com.datastax.cassandra</groupId>
- <artifactId>cassandra-driver-core</artifactId>
- <version>2.1.9</version>
- </dependency>
- </dependencies>
- <build>
- <plugins>
- <plugin>
- <artifactId>maven-assembly-plugin</artifactId>
- <configuration>
- <finalName>${project.artifactId}-cassandra-driver</finalName>
- </configuration>
- </plugin>
- </plugins>
- </build>
- </profile>
- </profiles>
- <dependencies>
- <dependency>
- <groupId>org.slf4j</groupId>
- <artifactId>slf4j-api</artifactId>
- <version>${slf4j.version}</version>
- </dependency>
- <dependency>
- <groupId>org.slf4j</groupId>
- <artifactId>slf4j-log4j12</artifactId>
- <version>${slf4j.version}</version>
- </dependency>
- </dependencies>
- </project>
- package cnauroth;
- import java.util.List;
- import com.datastax.driver.core.Cluster;
- import com.datastax.driver.core.ColumnMetadata;
- import com.datastax.driver.core.Session;
- class Main {
- public static void main(String[] args) throws Exception {
- // Skipping validation for brevity
- String address = args[0];
- String user = args[1];
- String password = args[2];
- String keyspace = args[3];
- String table = args[4];
- try (Cluster cluster = new Cluster.Builder()
- .addContactPoints(address)
- .withCredentials(user, password)
- .build()) {
- List<ColumnMetadata> columns =
- cluster.getMetadata().getKeyspace(keyspace).getTable(table).getColumns();
- for (ColumnMetadata column : columns) {
- System.out.println(column);
- }
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement