Skip to content

Commit f34877b

Browse files
clunclun
committed
add all sampels
1 parent b49b05a commit f34877b

File tree

9 files changed

+225
-9
lines changed

9 files changed

+225
-9
lines changed

‎examples/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
<dependency>
2020
<groupId>com.datastax.astra</groupId>
2121
<artifactId>astra-db-java</artifactId>
22-
<version>1.0.0-beta1</version>
22+
<version>1.0.0-beta2-SNAPSHOT</version>
2323
</dependency>
2424

2525
</dependencies>

‎examples/src/main/java/com/datastax/astra/client/collection/BulkWrite.java

Lines changed: 34 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,35 @@
1-
package com.datastax.astra.client.collection;public class BulkWrite {
1+
package com.datastax.astra.client.collection;
2+
3+
import com.datastax.astra.client.Collection;
4+
import com.datastax.astra.client.DataAPIClient;
5+
import com.datastax.astra.client.model.BulkWriteOptions;
6+
import com.datastax.astra.client.model.BulkWriteResult;
7+
import com.datastax.astra.client.model.Command;
8+
import com.datastax.astra.client.model.Document;
9+
import com.datastax.astra.internal.api.ApiResponse;
10+
11+
import java.util.List;
12+
13+
public class BulkWrite {
14+
public static void main(String[] args) {
15+
Collection<Document> collection = new DataAPIClient("TOKEN")
16+
.getDatabase("API_ENDPOINT")
17+
.getCollection("COLLECTION_NAME");
18+
19+
// Set a couple of Commands
20+
Command cmd1 = Command.create("insertOne").withDocument(new Document().id(1).append("name", "hello"));
21+
Command cmd2 = Command.create("insertOne").withDocument(new Document().id(2).append("name", "hello"));
22+
23+
// Set the options for the bulk write
24+
BulkWriteOptions options1 = BulkWriteOptions.Builder.ordered(false).concurrency(1);
25+
26+
// Execute the queries
27+
BulkWriteResult result = collection.bulkWrite(List.of(cmd1, cmd2), options1);
28+
29+
// Retrieve the LIST of responses
30+
for(ApiResponse res : result.getResponses()) {
31+
System.out.println(res.getData());
32+
}
33+
}
34+
235
}

‎examples/src/main/java/com/datastax/astra/client/collection/DeleteAll.java

Lines changed: 17 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,18 @@
1-
package com.datastax.astra.client.collection;public class DeleteAll {
1+
package com.datastax.astra.client.collection;
2+
3+
import com.datastax.astra.client.Collection;
4+
import com.datastax.astra.client.DataAPIClient;
5+
import com.datastax.astra.client.model.DeleteResult;
6+
import com.datastax.astra.client.model.Document;
7+
8+
public class DeleteAll {
9+
public static void main(String[] args) {
10+
Collection<Document> collection = new DataAPIClient("TOKEN")
11+
.getDatabase("API_ENDPOINT")
12+
.getCollection("COLLECTION_NAME");
13+
14+
// Show the deleted count
15+
DeleteResult result = collection.deleteAll();
16+
System.out.println("Deleted Count:" + result.getDeletedCount());
17+
}
218
}

‎examples/src/main/java/com/datastax/astra/client/collection/DeleteMany.java

Lines changed: 26 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,27 @@
1-
package com.datastax.astra.client.collection;public class DeleteMany {
1+
package com.datastax.astra.client.collection;
2+
3+
import com.datastax.astra.client.Collection;
4+
import com.datastax.astra.client.DataAPIClient;
5+
import com.datastax.astra.client.model.DeleteResult;
6+
import com.datastax.astra.client.model.Document;
7+
import com.datastax.astra.client.model.Filter;
8+
import com.datastax.astra.client.model.Filters;
9+
10+
import static com.datastax.astra.client.model.Filters.lt;
11+
12+
public class DeleteMany {
13+
public static void main(String[] args) {
14+
Collection<Document> collection = new DataAPIClient("TOKEN")
15+
.getDatabase("API_ENDPOINT")
16+
.getCollection("COLLECTION_NAME");
17+
18+
// Sample Filter
19+
Filter filter = Filters.and(
20+
Filters.gt("field2", 10),
21+
lt("field3", 20),
22+
Filters.eq("field4", "value"));
23+
DeleteResult result = collection.deleteMany(filter);
24+
System.out.println("Deleted Count:" + result.getDeletedCount());
25+
26+
}
227
}

‎examples/src/main/java/com/datastax/astra/client/collection/DeleteOne.java

Lines changed: 31 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,32 @@
1-
package com.datastax.astra.client.collection;public class DeleteOne {
1+
package com.datastax.astra.client.collection;
2+
3+
import com.datastax.astra.client.Collection;
4+
import com.datastax.astra.client.DataAPIClient;
5+
import com.datastax.astra.client.model.DeleteOneOptions;
6+
import com.datastax.astra.client.model.DeleteResult;
7+
import com.datastax.astra.client.model.Document;
8+
import com.datastax.astra.client.model.Filter;
9+
import com.datastax.astra.client.model.Filters;
10+
import com.datastax.astra.client.model.Sorts;
11+
12+
import static com.datastax.astra.client.model.Filters.lt;
13+
14+
public class DeleteOne {
15+
public static void main(String[] args) {
16+
Collection<Document> collection = new DataAPIClient("TOKEN")
17+
.getDatabase("API_ENDPOINT")
18+
.getCollection("COLLECTION_NAME");
19+
20+
// Sample Filter
21+
Filter filter = Filters.and(
22+
Filters.gt("field2", 10),
23+
lt("field3", 20),
24+
Filters.eq("field4", "value"));
25+
26+
// Delete one options
27+
DeleteOneOptions options = DeleteOneOptions.Builder
28+
.sort(Sorts.ascending("field2"));
29+
DeleteResult result = collection.deleteOne(filter, options);
30+
System.out.println("Deleted Count:" + result.getDeletedCount());
31+
}
232
}

‎examples/src/main/java/com/datastax/astra/client/collection/FindOneAndDelete.java

Lines changed: 27 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,28 @@
1-
package com.datastax.astra.client.collection;public class FindOneAndDelete {
1+
package com.datastax.astra.client.collection;
2+
3+
import com.datastax.astra.client.Collection;
4+
import com.datastax.astra.client.DataAPIClient;
5+
import com.datastax.astra.client.model.Document;
6+
import com.datastax.astra.client.model.Filter;
7+
import com.datastax.astra.client.model.Filters;
8+
9+
import java.util.Optional;
10+
11+
import static com.datastax.astra.client.model.Filters.lt;
12+
13+
public class FindOneAndDelete {
14+
public static void main(String[] args) {
15+
Collection<Document> collection = new DataAPIClient("TOKEN")
16+
.getDatabase("API_ENDPOINT")
17+
.getCollection("COLLECTION_NAME");
18+
19+
// Building a filter
20+
Filter filter = Filters.and(
21+
Filters.gt("field2", 10),
22+
lt("field3", 20),
23+
Filters.eq("field4", "value"));
24+
25+
// It will return the document before deleting it
26+
Optional<Document> docBeforeRelease = collection.findOneAndDelete(filter);
27+
}
228
}

‎examples/src/main/java/com/datastax/astra/client/collection/FindOneAndReplace.java

Lines changed: 43 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,44 @@
1-
package com.datastax.astra.client.collection;public class FindOneAndReplace {
1+
package com.datastax.astra.client.collection;
2+
3+
import com.datastax.astra.client.Collection;
4+
import com.datastax.astra.client.DataAPIClient;
5+
import com.datastax.astra.client.model.Document;
6+
import com.datastax.astra.client.model.Filter;
7+
import com.datastax.astra.client.model.Filters;
8+
import com.datastax.astra.client.model.FindOneAndReplaceOptions;
9+
import com.datastax.astra.client.model.Projections;
10+
import com.datastax.astra.client.model.Sorts;
11+
12+
import java.util.Optional;
13+
14+
import static com.datastax.astra.client.model.Filters.lt;
15+
16+
public class FindOneAndReplace {
17+
public static void main(String[] args) {
18+
Collection<Document> collection = new DataAPIClient("TOKEN")
19+
.getDatabase("API_ENDPOINT")
20+
.getCollection("COLLECTION_NAME");
21+
22+
// Building a filter
23+
Filter filter = Filters.and(
24+
Filters.gt("field2", 10),
25+
lt("field3", 20),
26+
Filters.eq("field4", "value"));
27+
28+
FindOneAndReplaceOptions options = FindOneAndReplaceOptions.Builder
29+
.projection(Projections.include("field1"))
30+
.sort(Sorts.ascending("field1"))
31+
.upsert(true)
32+
.returnDocumentAfter();
33+
34+
Document docForReplacement = new Document()
35+
.append("field1", "value1")
36+
.append("field2", 20)
37+
.append("field3", 30)
38+
.append("field4", "value4");
39+
40+
// It will return the document before deleting it
41+
Optional<Document> docBeforeReplace = collection
42+
.findOneAndReplace(filter, docForReplacement, options);
43+
}
244
}

‎examples/src/main/java/com/datastax/astra/client/collection/ReplaceOne.java

Lines changed: 45 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,46 @@
1-
package com.datastax.astra.client.collection;public class ReplaceOne {
1+
package com.datastax.astra.client.collection;
2+
3+
import com.datastax.astra.client.Collection;
4+
import com.datastax.astra.client.DataAPIClient;
5+
import com.datastax.astra.client.model.Document;
6+
import com.datastax.astra.client.model.Filter;
7+
import com.datastax.astra.client.model.Filters;
8+
import com.datastax.astra.client.model.FindOneAndReplaceOptions;
9+
import com.datastax.astra.client.model.Projections;
10+
import com.datastax.astra.client.model.ReplaceOneOptions;
11+
import com.datastax.astra.client.model.Sorts;
12+
import com.datastax.astra.client.model.UpdateResult;
13+
14+
import java.util.Optional;
15+
16+
import static com.datastax.astra.client.model.Filters.lt;
17+
18+
public class ReplaceOne {
19+
public static void main(String[] args) {
20+
Collection<Document> collection = new DataAPIClient("TOKEN")
21+
.getDatabase("API_ENDPOINT")
22+
.getCollection("COLLECTION_NAME");
23+
24+
// Building a filter
25+
Filter filter = Filters.and(
26+
Filters.gt("field2", 10),
27+
lt("field3", 20),
28+
Filters.eq("field4", "value"));
29+
30+
ReplaceOneOptions options = ReplaceOneOptions.Builder
31+
.upsert(true);
32+
33+
Document docForReplacement = new Document()
34+
.append("field1", "value1")
35+
.append("field2", 20)
36+
.append("field3", 30)
37+
.append("field4", "value4");
38+
39+
// It will return the document before deleting it
40+
UpdateResult res = collection.replaceOne(filter, docForReplacement, options);
41+
System.out.println("How many matches ?"+ res.getMatchedCount());
42+
System.out.println("How many has been modified ?"+ res.getModifiedCount());
43+
System.out.println("How many have been inserted ?"+ res.getUpsertedId());
44+
45+
}
246
}

‎tools/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
<dependency>
2020
<groupId>com.datastax.astra</groupId>
2121
<artifactId>astra-db-java</artifactId>
22-
<version>1.0.0-beta1</version>
22+
<version>1.0.0-beta2-SNAPSHOT</version>
2323
</dependency>
2424

2525
<dependency>

0 commit comments

Comments
 (0)