Insert documents (Java)
Inserts multiple documents into a collection.
Documents are stored in collections. They represent a single row or record of data in Hyper-Converged Database (HCD) databases. For more information, see About collections with the Data API (Java).
If the collection is vector-enabled, pregenerated vector embeddings can be included by using the reserved $vector field for each document.
You can later use the $vector field to perform a vector search.
|
Ready to write code? See the examples for this method to get started. If you are new to the Data API, check out the quickstart. |
Result
Inserts the specified documents and returns a wrapper (CollectionInsertManyResult) that includes the IDs of the inserted documents.
The ID value depends on the ID type. For more information, see Document IDs (Java).
Parameters
Use the insertMany method, which belongs to the com.datastax.astra.client.Collection class.
Method signature
CollectionInsertManyResult insertMany(
List<? extends T> documents
)
CollectionInsertManyResult insertMany(
List<? extends T> documents,
CollectionInsertManyOptions options
)
| Name | Type | Summary |
|---|---|---|
|
|
A list of objects describing the documents to insert. A document can contain user-defined and reserved fields. User-defined field names can be any non-empty sequence of Unicode characters, with the following exceptions:
Reserved fields are tied to specific functionality. Include the following reserved fields in your documents, if applicable:
For examples, see Examples. |
|
Optional.
The options for this operation. See Methods of the |
| Name | Type | Summary |
|---|---|---|
|
|
Optional.
Whether the insertions must be processed sequentially.
If For an example, see Insert documents and specify insertion behavior. |
|
|
Optional. The maximum number of concurrent requests to the API at a given time. If For an example, see Insert documents and specify insertion behavior. Default: |
|
|
Optional. The number of documents to include in a single API request. DataStax recommends leaving this parameter unspecified to use the system default. For an example, see Insert documents and specify insertion behavior. Maximum: Default: |
|
|
Optional. The maximum time, in milliseconds, that the client should wait for each underlying HTTP request. Default: The default value for the collection. This default is 30 seconds unless you specified a different default when you initialized the |
Examples
The following examples demonstrate how to insert multiple documents into a collection.
Insert documents
The documents can have different structures.
import com.datastax.astra.client.DataAPIClients;
import com.datastax.astra.client.collections.Collection;
import com.datastax.astra.client.collections.commands.results.CollectionInsertManyResult;
import com.datastax.astra.client.collections.definition.documents.Document;
import java.util.Arrays;
import java.util.List;
public class Example {
public static void main(String[] args) {
// Get an existing collection
Collection<Document> collection =
DataAPIClients.clientHCD("USERNAME", "PASSWORD")
.getDatabase("API_ENDPOINT", "KEYSPACE_NAME")
.getCollection("COLLECTION_NAME");
// Insert documents to the collection
Document document1 = new Document().append("name", "Jane Doe").append("age", 42);
Document document2 =
new Document()
.append("nickname", "Bobby")
.append("color", "blue")
.append("foods", Arrays.asList("carrots", "chocolate"));
CollectionInsertManyResult result = collection.insertMany(List.of(document1, document2));
System.out.println("IDs inserted: " + result.getInsertedIds());
}
}
Insert documents with vector embeddings
Use the reserved $vector field to insert documents with pregenerated vector embeddings.
All embeddings in the collection should use the same provider, model, and dimensions. Mismatched embeddings can cause inaccurate vector searches.
The $vector field is only supported for vector-enabled collections.
For more information, see Create a collection that can store vector embeddings and $vector in collections (Java).
You may also insert a mix of documents with and without the $vector field.
import com.datastax.astra.client.DataAPIClients;
import com.datastax.astra.client.collections.Collection;
import com.datastax.astra.client.collections.commands.results.CollectionInsertManyResult;
import com.datastax.astra.client.collections.definition.documents.Document;
import java.util.List;
public class Example {
public static void main(String[] args) {
// Get an existing collection
Collection<Document> collection =
DataAPIClients.clientHCD("USERNAME", "PASSWORD")
.getDatabase("API_ENDPOINT", "KEYSPACE_NAME")
.getCollection("COLLECTION_NAME");
// Insert documents to the collection
Document document1 =
new Document()
.append("name", "Jane Doe")
.append("age", 42)
.append("$vector", new float[] {0.08f, -0.62f, 0.39f});
Document document2 =
new Document()
.append("nickname", "Bobby")
.append("$vector", new float[] {0.12f, 0.53f, 0.32f});
CollectionInsertManyResult result = collection.insertMany(List.of(document1, document2));
System.out.println("IDs inserted: " + result.getInsertedIds());
}
}
Insert documents and specify the IDs
The Java client defines dedicated UUIDv6, UUIDv7, and ObjectId() classes.
UUIDs from the Java UUID class are implemented in the UUID v4 standard.
ObjectId classes are extracted from the BSON package.
When a unique identifier is retrieved from the server, it is converted to the appropriate class, based on the class definition in the defaultId option for the collection.
To generate new identifiers, you can use methods like new UUIDv6(), new UUIDv7(), or new ObjectId().
import com.datastax.astra.client.DataAPIClients;
import com.datastax.astra.client.collections.Collection;
import com.datastax.astra.client.collections.commands.results.CollectionInsertManyResult;
import com.datastax.astra.client.collections.definition.documents.Document;
import com.datastax.astra.client.collections.definition.documents.types.ObjectId;
import com.datastax.astra.client.collections.definition.documents.types.UUIDv7;
import java.util.List;
import java.util.UUID;
public class Example {
public static void main(String[] args) {
// Get an existing collection
Collection<Document> collection =
DataAPIClients.clientHCD("USERNAME", "PASSWORD")
.getDatabase("API_ENDPOINT", "KEYSPACE_NAME")
.getCollection("COLLECTION_NAME");
// Insert documents to the collection
Document document1 =
new Document()
.append("_id", new ObjectId("6672e1cbd7fabb4e5493916f"))
.append("name", "Melissa");
Document document2 = new Document().append("_id", new UUIDv7()).append("name", "Jess");
Document document3 = new Document().append("_id", UUID.randomUUID()).append("name", "Sam");
Document document4 = new Document().append("_id", 1).append("name", "Jane");
Document document5 = new Document().append("_id", "b_023").append("name", "Bobby");
CollectionInsertManyResult result =
collection.insertMany(List.of(document1, document2, document3, document4, document5));
System.out.println("IDs inserted: " + result.getInsertedIds());
}
}
Insert documents and specify insertion behavior
import com.datastax.astra.client.DataAPIClients;
import com.datastax.astra.client.collections.Collection;
import com.datastax.astra.client.collections.commands.options.CollectionInsertManyOptions;
import com.datastax.astra.client.collections.commands.results.CollectionInsertManyResult;
import com.datastax.astra.client.collections.definition.documents.Document;
import java.util.Arrays;
import java.util.List;
public class Example {
public static void main(String[] args) {
// Get an existing collection
Collection<Document> collection =
DataAPIClients.clientHCD("USERNAME", "PASSWORD")
.getDatabase("API_ENDPOINT", "KEYSPACE_NAME")
.getCollection("COLLECTION_NAME");
// Define the insertion options
CollectionInsertManyOptions options =
new CollectionInsertManyOptions().chunkSize(20).concurrency(3).ordered(false).timeout(1000);
// Insert documents into the collection
Document document1 = new Document().append("name", "Jane Doe").append("age", 42);
Document document2 =
new Document()
.append("nickname", "Bobby")
.append("color", "blue")
.append("foods", Arrays.asList("carrots", "chocolate"));
CollectionInsertManyResult result =
collection.insertMany(List.of(document1, document2), options);
System.out.println("IDs inserted: " + result.getInsertedIds());
}
}
Insert documents with a binary field
You can insert binary data as a byte array with $binary.
import com.datastax.astra.client.DataAPIClients;
import com.datastax.astra.client.collections.Collection;
import com.datastax.astra.client.collections.commands.results.CollectionInsertManyResult;
import com.datastax.astra.client.collections.definition.documents.Document;
import java.util.List;
import java.util.Map;
public class Example {
public static void main(String[] args) {
// Get an existing collection
Collection<Document> collection =
DataAPIClients.clientHCD("USERNAME", "PASSWORD")
.getDatabase("API_ENDPOINT", "KEYSPACE_NAME")
.getCollection("COLLECTION_NAME");
// Insert a document with a binary field
byte[] exampleBytes = {
(byte) 0x3D, (byte) 0xFB, (byte) 0xE7, (byte) 0x6D,
(byte) 0x3E, (byte) 0xE9, (byte) 0x78, (byte) 0xD5,
(byte) 0x3F, (byte) 0x49, (byte) 0xFB, (byte) 0xE7
};
Document document = new Document().append("exampleBinary", Map.of("$binary", exampleBytes));
CollectionInsertManyResult result = collection.insertMany(List.of(document));
System.out.println("IDs inserted: " + result.getInsertedIds());
}
}
Insert documents with nested fields
Although you can use dot notation in a filter to find a document, you cannot use dot notation to insert a document. To specify nested fields in the inserted document, you must build a map, list, or set.
import com.datastax.astra.client.DataAPIClients;
import com.datastax.astra.client.collections.Collection;
import com.datastax.astra.client.collections.commands.results.CollectionInsertManyResult;
import com.datastax.astra.client.collections.definition.documents.Document;
import java.util.List;
import java.util.Map;
public class Example {
public static void main(String[] args) {
// Get an existing collection
Collection<Document> collection =
DataAPIClients.clientHCD("USERNAME", "PASSWORD")
.getDatabase("API_ENDPOINT", "KEYSPACE_NAME")
.getCollection("COLLECTION_NAME");
// Insert documents into the collection
Document document1 =
new Document()
.append("title", "Hidden Shadows of the Past")
.append("genres", List.of("Biography", "Graphic Novel", "Dystopian", "Drama"))
.append(
"metadata",
Map.of(
"isbn", "978-1-905585-40-3",
"language", "French",
"edition", "Anniversary Edition"));
Document document2 =
new Document()
.append("title", "Bake a Dozen")
.append("genres", List.of("Biography", "Fiction"))
.append(
"metadata",
Map.of(
"isbn", "342-2-875587-50-2",
"language", "English",
"edition", "Illustrated Edition"));
CollectionInsertManyResult result = collection.insertMany(List.of(document1, document2));
System.out.println("IDs inserted: " + result.getInsertedIds());
}
}
Client reference
For more information, see the client reference.