Method clearDbTable

ZezeJava/ZezeJavaTest/src/Infinite/App.java:85–133

(TableX<K, ?> table)

		}

	public static <K extends Comparable<K>> void clearDbTable(TableX<K, ?> table) throws Exception {
		var t = System.nanoTime();
		table.__ClearTableCacheUnsafe__();
		//noinspection DataFlowIssue
		var dbTable = table.internalGetStorageForTestOnly("IKnownWhatIAmDoing").getDatabaseTable();
		var txnWrap = new Object() {
			Database.Transaction txn = dbTable.getDatabase().beginTransaction();
			int n;
			int total;
		};

		if (table.isUseRelationalMapping()) {
			var sqlKey = new SQLStatement();
			dbTable.walkDatabaseKey(table, k -> {
				sqlKey.clear();
				table.encodeKeySQLStatement(sqlKey, k);
				var txn = txnWrap.txn;
				dbTable.remove(txn, sqlKey);
				if (++txnWrap.n >= 10000) {
					txn.commit();
					txn.close();
					txnWrap.total += txnWrap.n;
					txnWrap.n = 0;
					txnWrap.txn = dbTable.getDatabase().beginTransaction();
				}
				return true;
			});
		} else {
			var bb = ByteBuffer.Allocate(0);
			((Database.AbstractKVTable)dbTable).walkKey(k -> {
				var txn = txnWrap.txn;
				bb.wraps(k);
				dbTable.remove(txn, bb);
				if (++txnWrap.n >= 10000) {
					txn.commit();
					txn.close();
					txnWrap.total += txnWrap.n;
					txnWrap.n = 0;
					txnWrap.txn = dbTable.getDatabase().beginTransaction();
				}
				return true;
			});
		}
		var txn = txnWrap.txn;
		txn.commit();
		txn.close();
		txnWrap.total += txnWrap.n;
		logger.info("clear table {}: {}, {} ms", table.getName(), txnWrap.total, (System.nanoTime() - t) / 1_000_000);
	}

	public void clearTables() throws Exception {
		clearDbTable(app.demo_Module1.getTable1());