Method testDbh2

ZezeJava/ZezeJavaTest/src/Dbh2/Dbh2Test.java:66–191

()

	}

	@Test
	public void testDbh2() throws Exception {
		Task.tryInitThreadPool();
		var database = new RocksDatabase("dbh2TestSimple");
		var bucket1 = new Bucket("""
				<?xml version="1.0" encoding="utf-8"?>
				<raft Name="">
					<node Host="127.0.0.1" Port="19000"/>
					<node Host="127.0.0.1" Port="19001"/>
					<node Host="127.0.0.1" Port="19002"/>
				</raft>
				""", database);
		var bucket2 = new Bucket("""
				<?xml version="1.0" encoding="utf-8"?>
				<raft Name="">
					<node Host="127.0.0.1" Port="19003"/>
					<node Host="127.0.0.1" Port="19004"/>
					<node Host="127.0.0.1" Port="19005"/>
				</raft>
				""", database);
		var serviceManager = Application.createServiceManager(Config.load(), "Dbh2ServiceManager");
		assert serviceManager != null;
		serviceManager.start();
		serviceManager.waitReady();
		Application.renameAndDeleteDirectory(new File("CommitRocks"));
		var dbh2AgentManager = new Dbh2AgentManager(serviceManager, null, 101);
		try {
			final var db = "database";
			final var tb1 = "table1";
			final var tb2 = "table2";

			var meta1 = new BBucketMeta.Data();
			meta1.setDatabaseName(db);
			meta1.setTableName(tb1);
			meta1.setRaftConfig("");
			meta1.setKeyFirst(Binary.Empty);
			meta1.setKeyLast(Binary.Empty);
			bucket1.agent().setBucketMeta(meta1); // 这个meta必须第一个设置。由于测试的meta一样，第二次运行重复设置是可以的。

			var meta2 = new BBucketMeta.Data();
			meta2.setDatabaseName(db);
			meta2.setTableName(tb2);
			meta2.setRaftConfig("");
			meta2.setKeyFirst(Binary.Empty);
			meta2.setKeyLast(Binary.Empty);
			bucket2.agent().setBucketMeta(meta2); // 这个meta必须第一个设置。由于测试的meta一样，第二次运行重复设置是可以的。

			var key = new Binary(new byte[]{1});
			var value = new Binary(new byte[]{1});

			dbh2AgentManager.start();
			{
				var batch = new BPrepareBatch.Data("", db, tb1, null);
				batch.getBatch().getPuts().put(key, value);
				batch.getBatch().setTid(dbh2AgentManager.nextTransactionId());
				bucket1.agent().prepareBatch(batch).await();
				bucket1.agent().commitBatch(batch.getBatch().getTid()).await();
			}