Method testFull

ZezeJava/ZezeJavaTest/src/Dbh2/Dbh2FullTest.java:147–213

()

	}

	@Test
	public void testFull() throws Exception {
		System.setProperty("Dbh2MasterDefaultBucketPortId", "18000");

		Task.tryInitThreadPool();

		var master = new Zeze.Dbh2.Master.Main("zeze.xml");
		var managers = new ArrayList<Dbh2Manager>();
		var serviceManager = Application.createServiceManager(Config.load(), "Dbh2ServiceManager");
		assert serviceManager != null;
		serviceManager.start();
		serviceManager.waitReady();
		Database database = null;
		Application.renameAndDeleteDirectory(new File("CommitRocks"));
		var dbh2AgentManager = new Dbh2AgentManager(serviceManager, null, 100);
		try {
			master.start();
			for (int i = 0; i < 3; ++i)
				managers.add(new Zeze.Dbh2.Dbh2Manager("manager" + i, "zeze" + i + ".xml"));
			for (var manager : managers)
				manager.start();
			dbh2AgentManager.start();

			database = newDatabase(dbh2AgentManager, "dbh2TestDb");
			var table1 = (Database.AbstractKVTable)database.openTable("table1", Bean.hash32("table1"));
			var table2 = (Database.AbstractKVTable)database.openTable("table2", Bean.hash32("table2"));
			table1.waitReady();
			table2.waitReady();

			var key = ByteBuffer.Wrap(ByteBuffer.Empty);
			var key1 = ByteBuffer.Wrap(new byte[]{1});
			var value = ByteBuffer.Wrap(new byte[]{1, 2, 3, 4});

			try (var trans = database.beginTransaction()) {
				table1.replace(trans, key, value);
				table1.replace(trans, key1, value);
				table2.replace(trans, key, value);
				table2.replace(trans, key1, value);
				trans.commit();
			}
			{
				var valueFindKey = table1.find(key);
				Assert.assertNotNull(valueFindKey);
				Assert.assertEquals(valueFindKey, value);

				var valueFindKey1 = table1.find(key1);
				Assert.assertNotNull(valueFindKey1);
				Assert.assertEquals(valueFindKey1, value);
			}
			{
				var valueFindKey = table2.find(key);
				Assert.assertNotNull(valueFindKey);
				Assert.assertEquals(valueFindKey, value);

				var valueFindKey1 = table2.find(key1);
				Assert.assertNotNull(valueFindKey1);
				Assert.assertEquals(valueFindKey1, value);
			}