From ee35d659924c67c042eb3b9a04c2bc79f20cca1a Mon Sep 17 00:00:00 2001
From: Lixfel <agga-games@gmx.de>
Date: Tue, 17 Jan 2023 19:26:19 +0100
Subject: [PATCH] Revert to null unsafe default

---
 src/de/steamwar/sql/internal/SelectStatement.java | 2 +-
 src/de/steamwar/sql/internal/Table.java           | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/de/steamwar/sql/internal/SelectStatement.java b/src/de/steamwar/sql/internal/SelectStatement.java
index 0b39160..e17dcb7 100644
--- a/src/de/steamwar/sql/internal/SelectStatement.java
+++ b/src/de/steamwar/sql/internal/SelectStatement.java
@@ -31,7 +31,7 @@ public class SelectStatement<T> extends Statement {
     private final Table<T> table;
 
     SelectStatement(Table<T> table, String... kfields) {
-        this(table, "SELECT " + Arrays.stream(table.fields).map(f -> f.identifier).collect(Collectors.joining(", ")) + " FROM " + table.name + " WHERE " + Arrays.stream(kfields).map(f -> f + Statement.NULL_SAFE_EQUALS + "?").collect(Collectors.joining(" AND ")));
+        this(table, "SELECT " + Arrays.stream(table.fields).map(f -> f.identifier).collect(Collectors.joining(", ")) + " FROM " + table.name + " WHERE " + Arrays.stream(kfields).map(f -> f + " = ?").collect(Collectors.joining(" AND ")));
     }
 
     public SelectStatement(Table<T> table, String sql) {
diff --git a/src/de/steamwar/sql/internal/Table.java b/src/de/steamwar/sql/internal/Table.java
index 3040642..cbad10a 100644
--- a/src/de/steamwar/sql/internal/Table.java
+++ b/src/de/steamwar/sql/internal/Table.java
@@ -75,7 +75,7 @@ public class Table<T> {
     }
 
     public Statement updateFields(String[] fields, String... kfields) {
-        return new Statement("UPDATE " + name + " SET " + Arrays.stream(fields).map(f -> f + " = ?").collect(Collectors.joining(", ")) + " WHERE " + Arrays.stream(kfields).map(f -> f + Statement.NULL_SAFE_EQUALS + "?").collect(Collectors.joining(" AND ")));
+        return new Statement("UPDATE " + name + " SET " + Arrays.stream(fields).map(f -> f + " = ?").collect(Collectors.joining(", ")) + " WHERE " + Arrays.stream(kfields).map(f -> f + " = ?").collect(Collectors.joining(" AND ")));
     }
 
     public Statement insert(String name) {
@@ -100,7 +100,7 @@ public class Table<T> {
     }
 
     public Statement deleteFields(String... kfields) {
-        return new Statement("DELETE FROM " + name + " WHERE " + Arrays.stream(kfields).map(f -> f + Statement.NULL_SAFE_EQUALS + "?").collect(Collectors.joining(" AND ")));
+        return new Statement("DELETE FROM " + name + " WHERE " + Arrays.stream(kfields).map(f -> f + " = ?").collect(Collectors.joining(" AND ")));
     }
 
     void ensureExistanceInSqlite() {