import java.sql.*;
public class CouchbaseConnection {
public static void main(String[] args) {
try {
Class.forName("com.couchbase.jdbc.CouchbaseDriver");
Connection connection = DriverManager.getConnection("jdbc:couchbase://localhost/default", "username", "password");
// ...
connection.close();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
import com.couchbase.client.java.*;
import com.couchbase.client.java.query.*;
public class CouchbaseQuery {
public static void main(String[] args) {
Cluster cluster = CouchbaseCluster.create("localhost");
Bucket bucket = cluster.openBucket("default", "password");
N1qlQueryResult result = bucket.query(N1qlQuery.simple("SELECT * FROM default WHERE age > 25"));
for (N1qlQueryRow row : result) {
System.out.println(row);
}
cluster.disconnect();
}
}
import com.couchbase.client.java.*;
import com.couchbase.client.java.query.*;
public class CouchbaseIndexing {
public static void main(String[] args) {
Cluster cluster = CouchbaseCluster.create("localhost");
Bucket bucket = cluster.openBucket("default", "password");
bucket.bucketManager().createN1qlIndex("age_index", true, false, "age");
N1qlQueryResult result = bucket.query(N1qlQuery.simple("SELECT * FROM default WHERE age > 25"));
for (N1qlQueryRow row : result) {
System.out.println(row);
}
cluster.disconnect();
}
}
