update sample

Author: clun

tools/src/main/java/com/datastax/astra/tool/CsvLoaderAnoop.java

@@ -17,11 +17,11 @@ public class CsvLoaderAnoop {
 
     public static void main(String[] args) throws Exception {
         DataAPIClient client =
-                new DataAPIClient("<replace_me>");
+                new DataAPIClient("AstraCS:rhZhqUkdzcYSlRNUfZjiZApq:c36d4c0575d4e471a93618a1586bf7b6be970fc3a5442f711fd79a932f98fb09");
         Database db =
-                client.getDatabase("<replace_me>");
+                client.getDatabase("https://07cae943-ea78-4d65-ac2a-a9e819e2d5d3-us-east1.apps.astra.datastax.com");
         Collection<Document> collection =
-                db.createCollection("anoop");
+                db.createCollection("best_buy2");
         collection.deleteAll();
         CsvLoader.load(
                 "/Users/cedricklunven/Downloads/anoop.csv",

tools/src/main/java/com/datastax/astra/tool/CsvLoaderLIsting.java

@@ -0,0 +1,40 @@
+package com.datastax.astra.tool;
+
+import com.datastax.astra.client.Collection;
+import com.datastax.astra.client.DataAPIClient;
+import com.datastax.astra.client.Database;
+import com.datastax.astra.client.model.DataAPIKeywords;
+import com.datastax.astra.client.model.Document;
+import com.datastax.astra.tool.csv.CsvLoader;
+import com.datastax.astra.tool.csv.CsvLoaderSettings;
+import com.datastax.astra.tool.csv.CsvRowMapper;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * Sample Code to load a CSV file into Astra using the DataStax Java Driver
+ */
+@Slf4j
+public class CsvLoaderListing {
+
+
+    public static void main(String[] args) throws Exception {
+        // Get an empty Collection
+        DataAPIClient        client      = new DataAPIClient("<replace_me>");
+        Database             db         = client.getDatabase("<replace_me>");
+        Collection<Document> collection = db.createCollection("airbnb");
+        collection.deleteAll();
+
+        // Zou !
+        String csvFilename = "/Users/cedricklunven/Downloads/listings.csv";
+        CsvLoader.load(csvFilename, collection, new CsvRowMapper() {
+            @Override
+            public Document map(Document doc) {
+                doc.put(DataAPIKeywords.ID.getKeyword(), doc.get("id"));
+                doc.remove("id");
+                return doc;
+            }
+        });
+
+    }
+
+}

tools/src/main/java/com/datastax/astra/tool/CsvLoaderListing.java

@@ -19,6 +19,16 @@
 @Slf4j
 public class CsvLoader {
 
+    /**
+     * Distributed import of CSV file into Astra.
+     *
+     * @throws Exception
+     *      exception in processing CSV
+     */
+    public static void load(String fileName, Collection<Document> collection, CsvRowMapper processor) throws Exception {
+        load(fileName, CsvLoaderSettings.builder().build(), collection, processor);
+    }
+
     /**
      * Distributed import of CSV file into Astra.
      *