Method main2

ZezeJava/ZezeJavaTest/src/Benchmark/BenchRocksDb.java:38–96

(String[] args)

	}

	public static void main2(String[] args) throws Exception {
		System.out.println("begin");
		RocksDB.loadLibrary();
		var dbHome = "~$BenchRocksDb";
		Application.renameAndDeleteDirectory(new File(dbHome));
		var cache = new LRUCache(8 * 1024 * 1024);
		var cfg = new BlockBasedTableConfig();
		cfg.setBlockCache(cache);
		Options commonOptions = new Options()
				.setCreateIfMissing(true)
				.setDbWriteBufferSize(64 << 20) // total write buffer bytes, include all the columns
				// .setRowCache(cache)
				.setTableFormatConfig(cfg)
				.setKeepLogFileNum(5);
		try (var rocksDb = RocksDB.open(commonOptions, dbHome)) {
			var k = new byte[4];
			var v = new byte[100];
			ThreadLocalRandom.current().nextBytes(v);
			var t = System.nanoTime();
			for (int i = 0; i < 100000; i++) {
				ByteBuffer.intBeHandler.set(k, 0, i);
				rocksDb.put(RocksDatabase.getDefaultWriteOptions(), k, v);
			}
			System.out.println((System.nanoTime() - t) / 1_000_000 + " ms");
			t = System.nanoTime();
			for (int i = 0; i < 100000; i++) {
				ByteBuffer.intBeHandler.set(k, 0, i);
				rocksDb.get(RocksDatabase.getDefaultReadOptions(), k);
			}
			System.out.println((System.nanoTime() - t) / 1_000_000 + " ms");
			var wb = new WriteBatch();
			t = System.nanoTime();
			for (int i = 0; i < 100000; i++) {
				ByteBuffer.intBeHandler.set(k, 0, i);
				wb.clear();
				wb.put(k, v);
				rocksDb.write(RocksDatabase.getDefaultWriteOptions(), wb);
			}
			System.out.println((System.nanoTime() - t) / 1_000_000 + " ms");
			wb.clear();
			t = System.nanoTime();
			for (int i = 0; i < 100000; i++) {
				ByteBuffer.intBeHandler.set(k, 0, i);
				wb.put(k, v);
			}
			rocksDb.write(RocksDatabase.getDefaultWriteOptions(), wb);
			System.out.println((System.nanoTime() - t) / 1_000_000 + " ms");

//			for (int i = 0; i < 256; i++)
//				rocksDb.put(new byte[]{(byte)i}, new byte[i]);
//			for (int i = 0; i < 256; i++)
//				System.out.println(rocksDb.get(new byte[]{(byte)i}).length);
			System.out.println(rocksDb.getProperty("rocksdb.estimate-table-readers-mem"));
			System.out.println(rocksDb.getProperty("rocksdb.cur-size-all-mem-tables"));
			System.out.println(cache.getUsage());
			System.out.println(cache.getPinnedUsage());
		}
		System.out.println("end");