Advertisement
Guest User

couchbase - bucket insert

a guest
Nov 3rd, 2014
350
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 3.95 KB | None | 0 0
  1.  
  2. import com.couchbase.client.deps.io.netty.buffer.*;
  3. import com.couchbase.client.deps.io.netty.util.CharsetUtil;
  4. import com.couchbase.client.java.Bucket;
  5. import com.couchbase.client.java.CouchbaseCluster;
  6. import com.couchbase.client.java.document.*;
  7. import com.couchbase.client.java.document.json.JsonArray;
  8. import com.couchbase.client.java.document.json.JsonObject;
  9. import java.util.logging.ConsoleHandler;
  10. import java.util.logging.Handler;
  11. import java.util.logging.Level;
  12. import java.util.logging.Logger;
  13.  
  14.  
  15. public class Test2 {
  16.  
  17.     public static void setLoggerLevels() {
  18.         Logger logger = Logger.getLogger("com.couchbase.client");
  19.         logger.setLevel(Level.OFF);
  20.         for (Handler h : logger.getParent().getHandlers()) {
  21.             if (h instanceof ConsoleHandler) {
  22.                 h.setLevel(Level.OFF);
  23.             }
  24.         }
  25.     }
  26.  
  27.     public static final String IP = "IP";
  28.     public static final String BUCKET = "BUCKET";
  29.  
  30.     public static void main(String[] args) {
  31.  
  32.         setLoggerLevels();
  33.  
  34.         CouchbaseCluster cluster = CouchbaseCluster.create(IP);
  35.  
  36.         try {
  37.             // CONNECT
  38.             Bucket bucket = cluster.openBucket(BUCKET);
  39.  
  40.             // EXAMPLE JSON
  41.             JsonObject json = JsonObject.create();
  42.             json.put("type", "value");
  43.             JsonArray jsonArray = JsonArray.create();
  44.             jsonArray.add("value1");
  45.  
  46.             // GENERATING DOCS
  47.             ByteBuf bb = Unpooled.copiedBuffer(json.toString(), CharsetUtil.UTF_8);
  48.             BinaryDocument bd = BinaryDocument.create("javabinary", bb);
  49.             bucket.upsert(bd);
  50.  
  51.             SerializableDocument sd = SerializableDocument.create("javaserial", json.toString());
  52.             bucket.upsert(sd);
  53.  
  54.             JsonArrayDocument jad = JsonArrayDocument.create("javaarray", jsonArray);
  55.             bucket.upsert(jad);
  56.  
  57.             JsonDocument jd = JsonDocument.create("javajson", json);
  58.             bucket.upsert(jd);
  59.  
  60.             JsonStringDocument jsd = JsonStringDocument.create("javajsonstring", json.toString());
  61.             bucket.upsert(jsd);
  62.  
  63.             LegacyDocument ld = LegacyDocument.create("javalegacy", json.toString());
  64.             bucket.upsert(ld);
  65.  
  66.             RawJsonDocument rd = RawJsonDocument.create("javarawjson", json.toString());
  67.             bucket.upsert(rd);
  68.  
  69.             StringDocument std = StringDocument.create("javastring", json.toString());
  70.             bucket.upsert(std);
  71.  
  72.             // READING
  73.             for (Class d : new Class[]{
  74.                 com.couchbase.client.java.document.BinaryDocument.class,
  75.                 com.couchbase.client.java.document.SerializableDocument.class,
  76.                 com.couchbase.client.java.document.JsonArrayDocument.class,
  77.                 com.couchbase.client.java.document.JsonDocument.class,
  78.                 com.couchbase.client.java.document.JsonStringDocument.class,
  79.                 com.couchbase.client.java.document.LegacyDocument.class,
  80.                 com.couchbase.client.java.document.RawJsonDocument.class,
  81.                 com.couchbase.client.java.document.SerializableDocument.class,
  82.                 com.couchbase.client.java.document.StringDocument.class,
  83.                 com.couchbase.client.java.document.Document.class
  84.             }) {
  85.                 for (String s : new String[]{
  86.                     "javabinary", "javaserial", "javaarray", "javajson",
  87.                     "javajsonstring", "javalegacy", "javarawjson", "javastring",
  88.                     "testphpjson", "testphparray", "testphpstring"}) {
  89.  
  90.                     try {
  91.                         Document o = bucket.get(s, d);
  92.                         System.out.println(d + " --> " + s + " --> " + o);
  93.                     } catch (Exception e) {
  94.                         //System.out.println(s+" --> "+e);
  95.                     }
  96.                 }
  97.             }
  98.  
  99.         } catch (Exception e) {
  100.             e.printStackTrace();
  101.         }
  102.  
  103.     }
  104.  
  105. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement