Skip to content

Commit

Permalink
Remove assert against "ASYNCDB key mismatch"
Browse files Browse the repository at this point in the history
  • Loading branch information
safris committed Sep 6, 2023
1 parent aa587fa commit a68b49c
Show file tree
Hide file tree
Showing 7 changed files with 7 additions and 43 deletions.
3 changes: 1 addition & 2 deletions ddlx/src/main/java/org/jaxdb/ddlx/Generator.java
Original file line number Diff line number Diff line change
Expand Up @@ -58,11 +58,10 @@ public final class Generator {
}

private static void trapPrintUsage() {
final String vendors = ArrayUtil.toString(DbVendor.values(), "|");
System.err.println("Usage: Generator <-d DEST_DIR> <-v VENDOR> <SCHEMA.ddlx>");
System.err.println();
System.err.println("Mandatory arguments:");
System.err.println(" -v <VENDOR> One of: <" + vendors + ">");
System.err.println(" -v <VENDOR> One of: <" + ArrayUtil.toString(DbVendor.values(), "|") + ">");
System.err.println(" -d <DEST_DIR> Specify the destination directory.");
System.exit(1);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@
import org.junit.Test;
import org.xml.sax.SAXException;

public abstract class CachingTest {
abstract class CachingTest {
private static final int sleepCascade = 5;

static final int iterations = 8;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
import org.libj.util.function.Throwing;

@FunctionalInterface
public interface ThrowingIntBooleanConsumer<E extends Throwable> extends IntBooleanConsumer {
interface ThrowingIntBooleanConsumer<E extends Throwable> extends IntBooleanConsumer {
@Override
default void accept(final int v1, final boolean v2) {
try {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
import org.libj.util.function.Throwing;

@FunctionalInterface
public interface ThrowingIntConsumer<E extends Throwable> extends IntConsumer {
interface ThrowingIntConsumer<E extends Throwable> extends IntConsumer {
@Override
default void accept(final int v1) {
try {
Expand Down
9 changes: 0 additions & 9 deletions jsql/src/main/java/org/jaxdb/jsql/Schema.java
Original file line number Diff line number Diff line change
Expand Up @@ -154,13 +154,4 @@ OnNotifyCallbackList getSession(final String sessionId) {
if (logger.isTraceEnabled()) logger.trace(getClass().getSimpleName() + ".getSession(" + sessionId + "): " + ObjectUtil.simpleIdentityString(onNotifyCallbackList));
return onNotifyCallbackList;
}

// FIXME: Remove this when confidence is high
static data.Key assertKey(final data.Key k1, final data.Key k2) {
if (k1.equals(k2))
return k1;

if (logger.isErrorEnabled()) logger.error("ASYNCDB key mismatch: " + k1 + " " + k2, new Exception());
return k2;
}
}
24 changes: 3 additions & 21 deletions jsql/src/main/java/org/jaxdb/jsql/generator/KeyModels.java
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,7 @@ class KeyModel {
private final String fromArgs;
private final String toArgs;

@SuppressWarnings("unchecked")
private final LinkedHashSet<String>[] resets = new LinkedHashSet[] {new LinkedHashSet<>(), new LinkedHashSet<>()};

private KeyModel(final String singletonInstanceName, final String cacheMethodName, final String toTableRefName, final ColumnModels columns, final IndexType indexType) {
Expand Down Expand Up @@ -88,24 +89,10 @@ private KeyModel(final String singletonInstanceName, final String cacheMethodNam
}

void writeReset(final StringBuilder b, final CurOld curlOld) {
for (final String reset : this.resets[curlOld.ordinal()])
for (final String reset : resets[curlOld.ordinal()])
b.append("\n ").append(reset);
}

void audit() {
// if (this.declare[0] != null && !this.declareCalled[0])
// throw new IllegalStateException();

// if (this.declare[1] != null && !this.declareCalled[1])
// throw new IllegalStateException();

// if (this.reset[0] != null && !this.resetCalled[0])
// throw new IllegalStateException();

// if (this.reset[1] != null && !this.resetCalled[1])
// throw new IllegalStateException();
}

String keyArgsExternal(final HashSet<String> declared) {
if (keyArgs == null)
return null;
Expand Down Expand Up @@ -144,15 +131,10 @@ String keyRefArgsInternal(final String cacheSingletonName, final String cacheMet
if (!declared.add(cacheColumnsRef + ":" + args))
return null;

final String key = data.Key.class.getCanonicalName() + ".with(" + cacheColumnsRef + ", " + args + ")";

// if (isForeign)
// return key;

final String args2 = keyClauseValues.replace("{1}.this.", "").replace("{2}", curlOld.toString());
final String args3 = args2.replace(".get" + curlOld, "").replace("()", "_").replace(", ", "");
final String name = "_" + ColumnModels.getInstanceNameForCache(cacheMethodName, args3) + "ON_" + toTableRefName + curlOld + "_Key$";
return "assertKey(" + (addSelfRef ? "self." : "") + include(cacheColumnsRef, name, args2, curlOld) + ", " + key + ")";
return (addSelfRef ? "self." : "") + include(cacheColumnsRef, name, args2, curlOld);
}

@Override
Expand Down
8 changes: 0 additions & 8 deletions jsql/src/main/java/org/jaxdb/jsql/generator/TableModel.java
Original file line number Diff line number Diff line change
Expand Up @@ -1386,14 +1386,6 @@ String makeTable() {
}

out.append(" }");

// Audit
for (final Map.Entry<ColumnModels,Relations<Relation>> entry : columnsToRelations.entrySet()) { // [S]
for (final Relation relation : entry.getValue()) { // [S]
relation.keyModel.audit();
}
}

return out.toString();
}

Expand Down

0 comments on commit a68b49c

Please sign in to comment.