.gitignore

@@ -7,19 +7,3 @@
 out/
 target
 compile/
-
-# eclipse specific git ignore
-*.pydevproject
-.project
-.metadata
-bin/**
-tmp/**
-tmp/**/*
-*.tmp
-*.bak
-*.swp
-*~.nib
-local.properties
-.classpath
-.settings/
-.loadpath

pom.xml

@@ -30,10 +30,6 @@
             <id>sk89q</id>
             <url>https://maven.sk89q.com/repo</url>
         </repository>
-        <repository>
-            <id>skript</id>
-            <url>https://repo.skriptlang.org/releases</url>
-        </repository>
     </repositories>
 
     <build>

src/main/java/com/btk5h/skriptdb/SkriptUtil.java

@@ -1,39 +1,37 @@
 package com.btk5h.skriptdb;
 
+import ch.njol.skript.Skript;
+import ch.njol.skript.lang.Expression;
+import ch.njol.skript.lang.VariableString;
+
 import java.lang.reflect.Field;
 import java.util.Arrays;
 import java.util.Optional;
 
-import org.bukkit.event.Event;
-
-import ch.njol.skript.ScriptLoader;
-import ch.njol.skript.Skript;
-import ch.njol.skript.lang.Expression;
-import ch.njol.skript.lang.VariableString;
-import ch.njol.skript.lang.parser.ParserInstance;
-
 public class SkriptUtil {
 
   private static final Field STRING;
   private static final Field EXPR;
 
   static {
-        STRING = tryGetOldStringField()
+    Field _FIELD = null;
-                .or(() -> tryGetNewStringField())
+    try {
-                .orElseGet(() -> {
+      _FIELD = VariableString.class.getDeclaredField("string");
+      _FIELD.setAccessible(true);
+    } catch (NoSuchFieldException e) {
       Skript.error("Skript's 'string' field could not be resolved.");
-                    return null;
+      e.printStackTrace();
-                });
+    }
+    STRING = _FIELD;
 
-        Field f = null;
     try {
       Optional<Class<?>> expressionInfo = Arrays.stream(VariableString.class.getDeclaredClasses())
           .filter(cls -> cls.getSimpleName().equals("ExpressionInfo"))
           .findFirst();
       if (expressionInfo.isPresent()) {
         Class<?> expressionInfoClass = expressionInfo.get();
-                f = expressionInfoClass.getDeclaredField("expr");
+        _FIELD = expressionInfoClass.getDeclaredField("expr");
-                f.setAccessible(true);
+        _FIELD.setAccessible(true);
       } else {
         Skript.error("Skript's 'ExpressionInfo' class could not be resolved.");
       }
@@ -41,7 +39,7 @@ public class SkriptUtil {
       e.printStackTrace();
       Skript.error("Skript's 'expr' field could not be resolved.");
     }
-        EXPR = f;
+    EXPR = _FIELD;
   }
 
   public static Object[] getTemplateString(VariableString vs) {
@@ -60,35 +58,4 @@ public class SkriptUtil {
     }
   }
 
-    @SuppressWarnings("deprecation")
-	public static boolean isCurrentEvent(Class<? extends Event> event) {
-        try {
-            Class.forName("ch.njol.skript.lang.parser.ParserInstance");
-            return ParserInstance.get().isCurrentEvent(event);
-        } catch (ClassNotFoundException e) {
-            return ScriptLoader.isCurrentEvent(event);
-        }
-    }
-    
-    
-    private static Optional<Field> tryGetOldStringField() {
-        try {
-            Field f = VariableString.class.getDeclaredField("string");
-            f.setAccessible(true);
-            return Optional.of(f);
-        } catch (NoSuchFieldException e) {
-            return Optional.empty();
-        }
-    }
-    
-    private static Optional<Field> tryGetNewStringField() {
-        try {
-            Field f = VariableString.class.getDeclaredField("strings");
-            f.setAccessible(true);
-            return Optional.of(f);
-        } catch (NoSuchFieldException e) {
-            return Optional.empty();
-        }
-    }
-
 }

src/main/java/com/btk5h/skriptdb/events/SQLQueryCompleteEvent.java

@@ -4,26 +4,32 @@ import org.bukkit.event.Event;
 import org.bukkit.event.HandlerList;
 
 public class SQLQueryCompleteEvent extends Event {
-    
+    private final static HandlerList HANDLERS = new HandlerList();
-	private static final HandlerList HANDLERS = new HandlerList();
-	
     private final String argument;
 
     public SQLQueryCompleteEvent(String argument) {
         super(true);
         this.argument = argument;
+        //  this.variables = variables;
+    }
+
+    public static HandlerList getHandlerList() {
+        return HANDLERS;
+    }
+
+    @Override
+    public String getEventName() {
+        return super.getEventName();
     }
 
     @Override
     public HandlerList getHandlers() {
-        return getHandlerList();
+        return HANDLERS;
     }
 
     public String getQuery() {
         return argument;
     }
 
-    public static HandlerList getHandlerList() {
+    //  public String getVariables() {return;}
-        return HANDLERS;
-    }
 }

src/main/java/com/btk5h/skriptdb/skript/EffExecuteStatement.java

@@ -25,7 +25,6 @@ import java.util.*;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
-import java.util.regex.Pattern;
 
 /**
  * Executes a statement on a database and optionally stores the result in a variable. Expressions
@@ -46,84 +45,106 @@ import java.util.regex.Pattern;
  */
 public class EffExecuteStatement extends Effect {
     private static final ExecutorService threadPool = Executors.newFixedThreadPool(SkriptDB.getInstance().getConfig().getInt("thread-pool-size", 10));
-    private static final Pattern ARGUMENT_PLACEHOLDER = Pattern.compile("(?<!\\\\)\\?");
     static String lastError;
 
     static {
         Skript.registerEffect(EffExecuteStatement.class,
-                "[quickly:quickly] execute %string% (in|on) %datasource% " +
+                "execute %string% (in|on) %datasource% " +
-                        "[with arg[ument][s] %-objects%] [and store [[the] (output|result)[s]] (to|in) [the] [var[iable]] %-objects%]");
+                        "[and store [[the] (output|result)[s]] (to|in) [the] [var[iable]] %-objects%]", "quickly execute %string% (in|on) %datasource% " +
+                        "[and store [[the] (output|result)[s]] (to|in) [the] [var[iable]] %-objects%]");
     }
 
     private Expression<String> query;
     private Expression<HikariDataSource> dataSource;
-    private Expression<Object> queryArguments;
+    private VariableString var;
-    private VariableString resultVariableName;
     private boolean isLocal;
     private boolean isList;
     private boolean quickly;
     private boolean isSync = false;
 
+    private void continueScriptExecution(Event e, Object populatedVariables) {
+        lastError = null;
+        if (populatedVariables instanceof String) {
+            lastError = (String) populatedVariables;
+        } else {
+
+            if (getNext() != null) {
+                ((Map<String, Object>) populatedVariables).forEach((name, value) -> setVariable(e, name, value));
+            }
+        }
+        TriggerItem.walk(getNext(), e);
+    }
+
     @Override
     protected void execute(Event e) {
         DataSource ds = dataSource.getSingle(e);
+        Pair<String, List<Object>> query = parseQuery(e);
+        String baseVariable = var != null ? var.toString(e).toLowerCase(Locale.ENGLISH) : null;
         //if data source isn't set
-        if (ds == null) {
+        if (ds == null) return;
-        	return;
-        }
-        Pair<String, List<Object>> parsedQuery = parseQuery(e);
-        String baseVariable = resultVariableName != null ? resultVariableName.toString(e).toLowerCase(Locale.ENGLISH) : null;
-        
         Object locals = Variables.removeLocals(e);
 
         //execute SQL statement
         if (Bukkit.isPrimaryThread()) {
-            CompletableFuture.supplyAsync(() -> executeStatement(ds, baseVariable, parsedQuery), threadPool)
+            CompletableFuture<Object> sql = CompletableFuture.supplyAsync(() -> executeStatement(ds, baseVariable, query), threadPool);
-		            .whenComplete((resources, err) -> {
+            sql.whenComplete((res, err) -> {
+                if (err != null) {
+                    err.printStackTrace();
+                }
                 //handle last error syntax data
-		            	resetLastSQLError();
+                lastError = null;
-		            	if (err instanceof SkriptDBQueryException) {
+                if (res instanceof String) {
-	            			setLastSQLError(err.getMessage());
+                    lastError = (String) res;
                 }
                 //if local variables are present
                 //bring back local variables
                 //populate SQL data into variables
                 if (!quickly) {
-		                    Bukkit.getScheduler().runTask(SkriptDB.getInstance(),
+                    Bukkit.getScheduler().runTask(SkriptDB.getInstance(), () -> {
-		                    		() -> postExecution(e, locals, resources));
+                        if (locals != null && getNext() != null) {
+                            Variables.setLocalVariables(e, locals);
+                        }
+                        if (!(res instanceof String)) {
+                            ((Map<String, Object>) res).forEach((name, value) -> setVariable(e, name, value));
+                        }
+                        TriggerItem.walk(getNext(), e);
+                        //the line below is required to prevent memory leaks
+                        Variables.removeLocals(e);
+                    });
                 } else {
-		                	postExecution(e, locals, resources);
+                    if (locals != null && getNext() != null) {
+                        Variables.setLocalVariables(e, locals);
+                    }
+                    if (!(res instanceof String)) {
+                        ((Map<String, Object>) res).forEach((name, value) -> setVariable(e, name, value));
+                    }
+                    TriggerItem.walk(getNext(), e);
+                    //the line below is required to prevent memory leaks
+                    Variables.removeLocals(e);
                 }
             });
             // sync executed SQL query, same as above, just sync
         } else {
             isSync = true;
-            Map<String, Object> resources = null;
+            Object resources = executeStatement(ds, baseVariable, query);
-			try {
-                resources = executeStatement(ds, baseVariable, parsedQuery);
-                resetLastSQLError();
-			} catch (SkriptDBQueryException err) {
             //handle last error syntax data
-				setLastSQLError(err.getMessage());
+            lastError = null;
+            if (resources instanceof String) {
+                lastError = (String) resources;
             }
             //if local variables are present
             //bring back local variables
             //populate SQL data into variables
-			postExecution(e, locals, resources);
-        }
-    }
-    
-    private void postExecution(Event e, Object locals, Map<String, Object> resources) {
             if (locals != null && getNext() != null) {
                 Variables.setLocalVariables(e, locals);
             }
-        if (resources != null) {
+            if (!(resources instanceof String)) {
-        	resources.forEach((name, value) -> setVariable(e, name, value));
+                ((Map<String, Object>) resources).forEach((name, value) -> setVariable(e, name, value));
             }
             TriggerItem.walk(getNext(), e);
-        //the line below is required to prevent memory leaks
             Variables.removeLocals(e);
         }
+    }
 
     @Override
     protected TriggerItem walk(Event e) {
@@ -136,80 +157,74 @@ public class EffExecuteStatement extends Effect {
     }
 
     private Pair<String, List<Object>> parseQuery(Event e) {
-        if (queryArguments != null) {
+        if (!(query instanceof VariableString)) {
-            Object[] args = queryArguments.getArray(e);
-            String queryString = query.getSingle(e);
-            int queryArgCount = (int) ARGUMENT_PLACEHOLDER.matcher(queryString).results().count();
-            if (queryArgCount != args.length) {
-                Skript.warning("Your query has %d question marks, but you provided %d arguments.");
-                args = Arrays.copyOf(args, queryArgCount);
-            }
-            return new Pair<>(query.getSingle(e), List.of(args));
-        } else if (query instanceof VariableString && !((VariableString) query).isSimple()) {
-            return parseVariableQuery(e, (VariableString) query);
-        }
             return new Pair<>(query.getSingle(e), null);
         }
+        VariableString q = (VariableString) query;
+        if (q.isSimple()) {
+            return new Pair<>(q.toString(e), null);
+        }
 
-    private Pair<String, List<Object>> parseVariableQuery(Event e, VariableString varQuery) {
         StringBuilder sb = new StringBuilder();
-        List<Object> parameters = new LinkedList<>();
+        List<Object> parameters = new ArrayList<>();
-        Object[] objects = SkriptUtil.getTemplateString(varQuery);
+        Object[] objects = SkriptUtil.getTemplateString(q);
 
         for (int i = 0; i < objects.length; i++) {
-            if (objects[i] instanceof String) {
+            Object o = objects[i];
-                sb.append(objects[i]);
+            if (o instanceof String) {
+                sb.append(o);
             } else {
-                Expression<?> expr = objects[i] instanceof Expression ? (Expression<?>) objects[i] : SkriptUtil.getExpressionFromInfo(objects[i]);
+                Expression<?> expr;
-                boolean standaloneString = isStandaloneString(objects, i);
+                if (o instanceof Expression)
+                    expr = (Expression<?>) o;
+                else
+                    expr = SkriptUtil.getExpressionFromInfo(o);
+
+                String before = getString(objects, i - 1);
+                String after = getString(objects, i + 1);
+                boolean standaloneString = false;
+
+                if (before != null && after != null) {
+                    if (before.endsWith("'") && after.endsWith("'")) {
+                        standaloneString = true;
+                    }
+                }
+
                 Object expressionValue = expr.getSingle(e);
 
-                Pair<String, Object> toAppend = parseExpressionQuery(expr, expressionValue, standaloneString);
+                if (expr instanceof ExprUnsafe) {
-                sb.append(toAppend.getFirst());
+                    sb.append(expressionValue);
-                if (toAppend.getSecond() != null) {
+
-                    parameters.add(toAppend.getSecond());
+                    if (standaloneString && expressionValue instanceof String) {
+                        String rawExpression = ((ExprUnsafe) expr).getRawExpression();
+                        Skript.warning(
+                                String.format("Unsafe may have been used unnecessarily. Try replacing 'unsafe %1$s' with %1$s",
+                                        rawExpression));
+                    }
+                } else {
+                    parameters.add(expressionValue);
+                    sb.append('?');
+
+                    if (standaloneString) {
+                        Skript.warning("Do not surround expressions with quotes!");
+                    }
                 }
             }
         }
         return new Pair<>(sb.toString(), parameters);
     }
 
-    private Pair<String, Object> parseExpressionQuery(Expression<?> expr, Object expressionValue, boolean standaloneString) {
+    private Object executeStatement(DataSource ds, String baseVariable, Pair<String, List<Object>> query) {
-        if (expr instanceof ExprUnsafe) {
-            if (standaloneString && expressionValue instanceof String) {
-                Skript.warning(
-                        String.format("Unsafe may have been used unnecessarily. Try replacing 'unsafe %1$s' with %1$s",
-                                ((ExprUnsafe) expr).getRawExpression()));
-            }
-            return new Pair<>((String) expressionValue, null);
-        } else {
-            if (standaloneString) {
-                Skript.warning("Do not surround expressions with quotes!");
-            }
-            return new Pair<>("?", expressionValue);
-        }
-    }
-
-    private Map<String, Object> executeStatement(DataSource ds, String baseVariable, Pair<String, List<Object>> query) throws SkriptDBQueryException {
         if (ds == null) {
-        	throw new SkriptDBQueryException("Data source is not set");
+            return "Data source is not set";
         }
-        try (Connection conn = ds.getConnection()) {
+        Map<String, Object> variableList = new HashMap<>();
-            try (PreparedStatement stmt = createStatement(conn, query)) {
+        try (Connection conn = ds.getConnection();
+             PreparedStatement stmt = createStatement(conn, query)) {
+
             boolean hasResultSet = stmt.execute();
 
             if (baseVariable != null) {
-                    return processBaseVariable(baseVariable, stmt, hasResultSet);
-                }
-                return Map.of();
-            }
-        } catch (SQLException ex) {
-            throw new SkriptDBQueryException(ex.getMessage());
-        }
-    }
-    
-    private Map<String, Object> processBaseVariable(String baseVariable, PreparedStatement stmt, boolean hasResultSet) throws SQLException {
-        Map<String, Object> variableList = new HashMap<>();
                 if (isList) {
                     baseVariable = baseVariable.substring(0, baseVariable.length() - 1);
                 }
@@ -219,20 +234,6 @@ public class EffExecuteStatement extends Effect {
                     crs.populate(stmt.getResultSet());
 
                     if (isList) {
-                return fetchQueryResultSet(crs, baseVariable);
-            } else {
-                crs.last();
-                variableList.put(baseVariable, crs.getRow());
-            }
-        } else if (!isList) {
-            //if no results are returned and the specified variable isn't a list variable, put the affected rows count in the variable
-            return Map.of(baseVariable, stmt.getUpdateCount());
-        }
-        return Map.of();
-    }
-    
-    private Map<String, Object> fetchQueryResultSet(CachedRowSet crs, String baseVariable) throws SQLException {
-        Map<String, Object> variableList = new HashMap<>();
                         ResultSetMetaData meta = crs.getMetaData();
                         int columnCount = meta.getColumnCount();
 
@@ -242,6 +243,7 @@ public class EffExecuteStatement extends Effect {
                         }
 
                         int rowNumber = 1;
+                        try {
                             while (crs.next()) {
                                 for (int i = 1; i <= columnCount; i++) {
                                     variableList.put(baseVariable + meta.getColumnLabel(i).toLowerCase(Locale.ENGLISH)
@@ -249,31 +251,48 @@ public class EffExecuteStatement extends Effect {
                                 }
                                 rowNumber++;
                             }
+                        } catch (SQLException ex) {
+                            return ex.getMessage();
+                        }
+                    } else {
+                        crs.last();
+                        variableList.put(baseVariable, crs.getRow());
+                    }
+                } else if (!isList) {
+                    //if no results are returned and the specified variable isn't a list variable, put the affected rows count in the variable
+                    variableList.put(baseVariable, stmt.getUpdateCount());
+                }
+            }
+        } catch (SQLException ex) {
+            return ex.getMessage();
+        }
         return variableList;
     }
 
     private PreparedStatement createStatement(Connection conn, Pair<String, List<Object>> query) throws SQLException {
         PreparedStatement stmt = conn.prepareStatement(query.getFirst());
-        if (query.getSecond() != null) {
+        List<Object> parameters = query.getSecond();
-            Iterator<Object> iter = query.getSecond().iterator();
+
-            for (int i = 1; iter.hasNext(); i++) {
+        if (parameters != null) {
-                stmt.setObject(i, iter.next());
+            for (int i = 0; i < parameters.size(); i++) {
+                stmt.setObject(i + 1, parameters.get(i));
             }
         }
 
         return stmt;
     }
 
-    private boolean isStandaloneString(Object[] objects, int index) {
+    private String getString(Object[] objects, int index) {
-        String before = getString(objects, index - 1);
+        if (index < 0 || index >= objects.length) {
-        String after = getString(objects, index + 1);
+            return null;
-        return before != null && before.endsWith("'") && after != null && after.endsWith("'");
         }
 
-    private String getString(Object[] objects, int index) {
+        Object object = objects[index];
-        if (index >= 0 && index < objects.length && objects[index] instanceof String) {
+
-            return (String) objects[index];
+        if (object instanceof String) {
+            return (String) object;
         }
+
         return null;
     }
 
@@ -281,7 +300,7 @@ public class EffExecuteStatement extends Effect {
 
         //fix mediumblob and similar column types, so they return a String correctly
         if (obj != null) {
-            if (obj instanceof byte[]) {
+            if (obj.getClass().getName().equals("[B")) {
                 obj = new String((byte[]) obj);
 
                 //in some servers instead of being byte array, it appears as SerialBlob (depends on mc version, 1.12.2 is bvte array, 1.16.5 SerialBlob)
@@ -296,14 +315,6 @@ public class EffExecuteStatement extends Effect {
         Variables.setVariable(name.toLowerCase(Locale.ENGLISH), obj, e, isLocal);
     }
 
-    private static void resetLastSQLError() {
-    	lastError = null;
-    }
-    
-    private static void setLastSQLError(String error) {
-    	lastError = error;
-    }
-
     @Override
     public String toString(Event e, boolean debug) {
         return "execute " + query.toString(e, debug) + " in " + dataSource.toString(e, debug);
@@ -311,7 +322,8 @@ public class EffExecuteStatement extends Effect {
 
     @SuppressWarnings("unchecked")
     @Override
-    public boolean init(Expression<?>[] exprs, int matchedPattern, Kleenean isDelayed, SkriptParser.ParseResult parseResult) {
+    public boolean init(Expression<?>[] exprs, int matchedPattern, Kleenean isDelayed,
+                        SkriptParser.ParseResult parseResult) {
         Expression<String> statementExpr = (Expression<String>) exprs[0];
         if (statementExpr instanceof VariableString || statementExpr instanceof ExprUnsafe) {
             query = statementExpr;
@@ -322,34 +334,17 @@ public class EffExecuteStatement extends Effect {
             return false;
         }
         dataSource = (Expression<HikariDataSource>) exprs[1];
-        if (exprs[2] != null) {
+        Expression<?> expr = exprs[2];
-            if (query instanceof VariableString && !((VariableString) query).isSimple()) {
+        quickly = matchedPattern == 1;
-                Skript.warning("Your query string contains expresions, but you've also provided query arguments. Consider using `unsafe` keyword before your query.");
+        if (expr instanceof Variable) {
-            }
+            Variable<?> varExpr = (Variable<?>) expr;
-            queryArguments = (Expression<Object>) exprs[2];
+            var = varExpr.getName();
-        }
-        Expression<?> resultHolder = exprs[3];
-        quickly = parseResult.hasTag("quickly");
-        if (resultHolder instanceof Variable) {
-            Variable<?> varExpr = (Variable<?>) resultHolder;
-            resultVariableName = varExpr.getName();
             isLocal = varExpr.isLocal();
             isList = varExpr.isList();
-        } else if (resultHolder != null) {
+        } else if (expr != null) {
-            Skript.error(resultHolder + " is not a variable");
+            Skript.error(expr + " is not a variable");
             return false;
         }
         return true;
     }
-    
-    public static class SkriptDBQueryException extends RuntimeException {
-
-		private static final long serialVersionUID = -1869895286406538884L;
-		
-		public SkriptDBQueryException(String message) {
-			super(message);
-		}
-    	
-    }
-    
 }

src/main/java/com/btk5h/skriptdb/skript/ExprDataSource.java

@@ -32,9 +32,8 @@ public class ExprDataSource extends SimpleExpression<HikariDataSource> {
 
     static {
         Skript.registerExpression(ExprDataSource.class, HikariDataSource.class,
-                ExpressionType.COMBINED, "[the] data(base|[ ]source) [(of|at)] %string% "
+                ExpressionType.COMBINED, "[the] data(base|[ ]source) [(of|at)] %string% " +
-                		+ "[with [a] [max[imum]] [connection] life[ ]time of %-timespan%] "
+                        "[with [a] [max[imum]] [connection] life[ ]time of %-timespan%] " + "[[(using|with)] [a] driver %-string%]");
-                		+ "[[(using|with)] [a] driver %-string%]");
     }
 
     private Expression<String> url;
@@ -101,7 +100,8 @@ public class ExprDataSource extends SimpleExpression<HikariDataSource> {
 
     @SuppressWarnings("unchecked")
     @Override
-    public boolean init(Expression<?>[] exprs, int matchedPattern, Kleenean isDelayed, SkriptParser.ParseResult parseResult) {
+    public boolean init(Expression<?>[] exprs, int matchedPattern, Kleenean isDelayed,
+                        SkriptParser.ParseResult parseResult) {
         url = (Expression<String>) exprs[0];
         maxLifetime = (Expression<Timespan>) exprs[1];
         driver = (Expression<String>) exprs[2];

src/main/java/com/btk5h/skriptdb/skript/ExprSQLQuery.java

@@ -1,10 +1,6 @@
 package com.btk5h.skriptdb.skript;
 
-import org.bukkit.event.Event;
+import ch.njol.skript.ScriptLoader;
-
-import com.btk5h.skriptdb.SkriptUtil;
-import com.btk5h.skriptdb.events.SQLQueryCompleteEvent;
-
 import ch.njol.skript.Skript;
 import ch.njol.skript.lang.Expression;
 import ch.njol.skript.lang.ExpressionType;
@@ -12,6 +8,8 @@ import ch.njol.skript.lang.SkriptParser;
 import ch.njol.skript.lang.util.SimpleExpression;
 import ch.njol.skript.log.ErrorQuality;
 import ch.njol.util.Kleenean;
+import com.btk5h.skriptdb.events.SQLQueryCompleteEvent;
+import org.bukkit.event.Event;
 
 /**
  * Stores the error from the last executed statement, if there was one.
@@ -53,7 +51,7 @@ public class ExprSQLQuery extends SimpleExpression<String> {
 
     @Override
     public boolean init(final Expression<?>[] expressions, final int matchedPattern, final Kleenean isDelayed, final SkriptParser.ParseResult parseResult) {
-        if (!SkriptUtil.isCurrentEvent(SQLQueryCompleteEvent.class)) {
+        if (!ScriptLoader.isCurrentEvent(SQLQueryCompleteEvent.class)) {
             Skript.error("Cannot use 'sql query' outside of a complete of sql query event", ErrorQuality.SEMANTIC_ERROR);
             return false;
         }

src/main/java/com/btk5h/skriptdb/skript/ExprUnsafe.java

@@ -53,7 +53,8 @@ public class ExprUnsafe extends SimpleExpression<String> {
 
     @SuppressWarnings("unchecked")
     @Override
-    public boolean init(Expression<?>[] exprs, int matchedPattern, Kleenean isDelayed, SkriptParser.ParseResult parseResult) {
+    public boolean init(Expression<?>[] exprs, int matchedPattern, Kleenean isDelayed,
+                        SkriptParser.ParseResult parseResult) {
         stringExpression = (Expression<String>) exprs[0];
         rawExpression = parseResult.expr.substring("unsafe".length()).trim();
         return true;