Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import com.couchbase.client.deps.io.netty.buffer.*;
- import com.couchbase.client.deps.io.netty.util.CharsetUtil;
- import com.couchbase.client.java.Bucket;
- import com.couchbase.client.java.CouchbaseCluster;
- import com.couchbase.client.java.document.*;
- import com.couchbase.client.java.document.json.JsonArray;
- import com.couchbase.client.java.document.json.JsonObject;
- import java.util.logging.ConsoleHandler;
- import java.util.logging.Handler;
- import java.util.logging.Level;
- import java.util.logging.Logger;
- public class Test2 {
- public static void setLoggerLevels() {
- Logger logger = Logger.getLogger("com.couchbase.client");
- logger.setLevel(Level.OFF);
- for (Handler h : logger.getParent().getHandlers()) {
- if (h instanceof ConsoleHandler) {
- h.setLevel(Level.OFF);
- }
- }
- }
- public static final String IP = "IP";
- public static final String BUCKET = "BUCKET";
- public static void main(String[] args) {
- setLoggerLevels();
- CouchbaseCluster cluster = CouchbaseCluster.create(IP);
- try {
- // CONNECT
- Bucket bucket = cluster.openBucket(BUCKET);
- // EXAMPLE JSON
- JsonObject json = JsonObject.create();
- json.put("type", "value");
- JsonArray jsonArray = JsonArray.create();
- jsonArray.add("value1");
- // GENERATING DOCS
- ByteBuf bb = Unpooled.copiedBuffer(json.toString(), CharsetUtil.UTF_8);
- BinaryDocument bd = BinaryDocument.create("javabinary", bb);
- bucket.upsert(bd);
- SerializableDocument sd = SerializableDocument.create("javaserial", json.toString());
- bucket.upsert(sd);
- JsonArrayDocument jad = JsonArrayDocument.create("javaarray", jsonArray);
- bucket.upsert(jad);
- JsonDocument jd = JsonDocument.create("javajson", json);
- bucket.upsert(jd);
- JsonStringDocument jsd = JsonStringDocument.create("javajsonstring", json.toString());
- bucket.upsert(jsd);
- LegacyDocument ld = LegacyDocument.create("javalegacy", json.toString());
- bucket.upsert(ld);
- RawJsonDocument rd = RawJsonDocument.create("javarawjson", json.toString());
- bucket.upsert(rd);
- StringDocument std = StringDocument.create("javastring", json.toString());
- bucket.upsert(std);
- // READING
- for (Class d : new Class[]{
- com.couchbase.client.java.document.BinaryDocument.class,
- com.couchbase.client.java.document.SerializableDocument.class,
- com.couchbase.client.java.document.JsonArrayDocument.class,
- com.couchbase.client.java.document.JsonDocument.class,
- com.couchbase.client.java.document.JsonStringDocument.class,
- com.couchbase.client.java.document.LegacyDocument.class,
- com.couchbase.client.java.document.RawJsonDocument.class,
- com.couchbase.client.java.document.SerializableDocument.class,
- com.couchbase.client.java.document.StringDocument.class,
- com.couchbase.client.java.document.Document.class
- }) {
- for (String s : new String[]{
- "javabinary", "javaserial", "javaarray", "javajson",
- "javajsonstring", "javalegacy", "javarawjson", "javastring",
- "testphpjson", "testphparray", "testphpstring"}) {
- try {
- Document o = bucket.get(s, d);
- System.out.println(d + " --> " + s + " --> " + o);
- } catch (Exception e) {
- //System.out.println(s+" --> "+e);
- }
- }
- }
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement