Method load

ZezeJava/ZezeJava/src/main/java/Zeze/Transaction/TableX.java:176–296

(@NotNull K key)

	}

	@SuppressWarnings("unchecked")
	private @NotNull AtomicTupleRecord<K, V> load(@NotNull K key) {
		var tkey = new TableKey(getId(), key);
		while (true) {
			var r = cache.getOrAdd(key, () -> new Record1<>(this, key, null));
			r.enterFairLock(); // 对同一个记录，不允许重入。
			V strongRef = null;
			try {
				if (r.getState() == StateRemoved)
					continue; // 正在被删除，重新 GetOrAdd 一次。以后 _lock_check_ 里面会再次检查这个状态。

				if (r.getState() == StateShare
						|| r.getState() == StateModify) {
					var beforeTimestamp = r.getTimestamp(); // read timestamp before read value。see Record1.Commit
					strongRef = (V)r.getSoftValue();
					if (strongRef == null && !r.getDirty()) {
						var find = localRocksCacheTable.find(this, key);
						if (find != null) {
							strongRef = find;
							strongRef.initRootInfo(r.createRootInfoIfNeed(tkey), null);
							r.setSoftValue(strongRef);
						}
					}
					return new AtomicTupleRecord<>(r, strongRef, beforeTimestamp);
				}

				var acquire = r.acquire(StateShare, false, false);
				//noinspection DataFlowIssue
				r.setState(acquire.resultState);
				if (r.getState() == StateInvalid) {
					var msg = "Acquire Failed (Redo): " + r;
					var txn = Transaction.getCurrent();
					if (txn == null || txn.isCompleted())
						throw new GoBackZeze(msg);
					txn.throwRedoAndReleaseLock(getId(), msg, null);
					// never run here
				}
				try {
					verifyGlobalRecordState(key, r.getState() == StateModify);

					r.setTimestamp(Record.getNextTimestamp());
					r.setFreshAcquire();
					var beforeTimestamp = r.getTimestamp();

					var storage = this.storage;
					if (storage != null) {
						if (ZezeCounter.instance != null)
							ZezeCounter.instance.getOrAddTableInfo(getId()).storageGet().increment();
						strongRef = storage.getDatabaseTable().find(this, key);
						if (strongRef != null)
							rocksCachePut(key, strongRef);
						else
							rocksCacheRemove(key);
						r.setSoftValue(strongRef); // r.Value still maybe null
						// 【注意】这个变量不管 OldTable 中是否存在的情况。
//						r.setExistInBackDatabase(strongRef != null);

						// 当记录删除时需要同步删除 OldTable，否则下一次又会从 OldTable 中找到。