Skip to content

Commit e15bf5a

Browse files
added datastax driver and apache commons csv parser to pom. added driver session to app
1 parent 82e82d3 commit e15bf5a

File tree

2 files changed

+18
-0
lines changed

2 files changed

+18
-0
lines changed

pom.xml

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,20 @@
5353
<artifactId>slf4j-log4j12</artifactId>
5454
<version>1.7.7</version>
5555
</dependency>
56+
57+
<dependency>
58+
<groupId>com.datastax.cassandra</groupId>
59+
<artifactId>cassandra-driver-core</artifactId>
60+
<version>3.1.0</version>
61+
</dependency>
62+
63+
<dependency>
64+
<groupId>org.apache.commons</groupId>
65+
<artifactId>commons-csv</artifactId>
66+
<version>1.3</version>
67+
</dependency>
68+
69+
5670
</dependencies>
5771

5872
<build>

src/main/java/com/datastax/cdm/CassandraDatasetManager.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package com.datastax.cdm;
22

3+
import com.datastax.driver.core.Session;
34
import com.fasterxml.jackson.core.type.TypeReference;
45
import com.fasterxml.jackson.databind.ObjectMapper;
56
import com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
@@ -26,6 +27,7 @@ public class CassandraDatasetManager {
2627

2728
private static final String YAML_URI = "https://raw.githubusercontent.com/riptano/cdm-java/master/datasets.yaml";
2829
private Map<String, Dataset> datasets;
30+
private Session session;
2931

3032
CassandraDatasetManager(Map<String, Dataset> datasets) {
3133
this.datasets = datasets;
@@ -80,6 +82,8 @@ public static void main(String[] args) throws IOException, ParseException, Inter
8082
return;
8183
}
8284

85+
// connect to the cluster via the driver
86+
8387
if(args[0].equals("install")) {
8488
cdm.install(args[1]);
8589
} else if (args[0].equals("list")) {

0 commit comments

Comments
 (0)