Add more protections against MariaDB 1020

Affects issues:
- #4468

Author: AuroraLS3

Plan/common/src/main/java/com/djrapitops/plan/extension/implementation/storage/transactions/results/StorePlayerTableResultTransaction.java

@@ -67,6 +67,11 @@ public StorePlayerTableResultTransaction(ProviderInformation information, Parame
         this(information.getPluginName(), parameters.getServerUUID(), information.getName(), parameters.getPlayerUUID(), value);
     }
 
+    @Override
+    protected IsolationLevel getDesiredIsolationLevel() {
+        return IsolationLevel.READ_COMMITTED;
+    }
+
     @Override
     protected void performOperations() {
         execute(storeValue());
@@ -80,26 +85,45 @@ private Executable storeValue() {
             }
 
             Integer tableID = query(tableID());
+            query(lockRows(tableID));
 
             List<Object[]> rows = table.getRows();
             Integer oldRowCount = query(currentRowCount(tableID));
             int newRowCount = rows.size();
 
             if (oldRowCount < newRowCount) {
-                updateRows(tableID, oldRowCount, rows);
                 insertNewRows(tableID, oldRowCount, rows);
+                updateRows(tableID, oldRowCount, rows);
             } else if (oldRowCount == newRowCount) {
                 // No need to delete or insert rows
                 updateRows(tableID, oldRowCount, rows);
             } else {
                 // oldRowCount > newRowCount
-                updateRows(tableID, newRowCount, rows);
                 deleteOldRows(tableID, newRowCount);
+                updateRows(tableID, newRowCount, rows);
             }
             return false;
         };
     }
 
+    private Query<Object> lockRows(Integer tableID) {
+        String sql = SELECT + "*" + FROM + TABLE_NAME +
+                WHERE + TABLE_ID + "=?" +
+                AND + USER_UUID + "=?" + lockForUpdate();
+        return new QueryStatement<>(sql) {
+            @Override
+            public void prepare(PreparedStatement statement) throws SQLException {
+                statement.setInt(1, tableID);
+                statement.setString(2, playerUUID.toString());
+            }
+
+            @Override
+            public Object processResults(ResultSet set) {
+                return null;
+            }
+        };
+    }
+
     private void deleteOldRows(Integer tableID, int afterRow) {
         String sql = DELETE_FROM + TABLE_NAME +
                 WHERE + TABLE_ID + "=?" +

Plan/common/src/main/java/com/djrapitops/plan/extension/implementation/storage/transactions/results/StoreServerTableResultTransaction.java

@@ -69,6 +69,11 @@ protected void performOperations() {
         execute(storeValue());
     }
 
+    @Override
+    protected IsolationLevel getDesiredIsolationLevel() {
+        return IsolationLevel.READ_COMMITTED;
+    }
+
     private Executable storeValue() {
         return connection -> {
             int maxColumnSize = table.getMaxColumnSize();
@@ -83,15 +88,15 @@ private Executable storeValue() {
             int newRowCount = rows.size();
 
             if (oldRowCount < newRowCount) {
-                updateRows(tableID, oldRowCount, rows);
                 insertNewRows(tableID, oldRowCount, rows);
+                updateRows(tableID, oldRowCount, rows);
             } else if (oldRowCount == newRowCount) {
                 // No need to delete or insert rows
                 updateRows(tableID, oldRowCount, rows);
             } else {
                 // oldRowCount > newRowCount
-                updateRows(tableID, newRowCount, rows);
                 deleteOldRows(tableID, newRowCount);
+                updateRows(tableID, newRowCount, rows);
             }
             return false;
         };

Plan/common/src/main/java/com/djrapitops/plan/storage/database/transactions/Transaction.java

@@ -183,13 +183,23 @@ private void initializeConnection(SQLDB db) {
     }
 
     private void initializeTransaction() {
+        setIsolationLevel();
         try {
             createSavePoint();
         } catch (SQLException e) {
             throw new DBOpException(getClass().getSimpleName() + " save point initialization failed: " + e.getMessage(), e);
         }
     }
 
+    private void setIsolationLevel() {
+        if (dbType == DBType.MYSQL && attempts == 1) {
+            IsolationLevel desiredIsolationLevel = getDesiredIsolationLevel();
+            if (desiredIsolationLevel != IsolationLevel.UNCHANGED) {
+                execute("SET TRANSACTION ISOLATION LEVEL " + desiredIsolationLevel.name().replace('_', ' '));
+            }
+        }
+    }
+
     private void createSavePoint() throws SQLException {
         try {
             this.savepoint = connection.setSavepoint();
@@ -298,4 +308,13 @@ protected boolean hasTable(String tableName) {
     }
 
     protected String lockForUpdate() {return db.getSql().lockForUpdate();}
+
+    protected IsolationLevel getDesiredIsolationLevel() {
+        return IsolationLevel.UNCHANGED;
+    }
+
+    public enum IsolationLevel {
+        UNCHANGED,
+        READ_COMMITTED
+    }
 }

Plan/common/src/main/java/com/djrapitops/plan/storage/database/transactions/init/CreateIndexTransaction.java

@@ -19,6 +19,8 @@
 import com.djrapitops.plan.storage.database.DBType;
 import com.djrapitops.plan.storage.database.queries.schema.MySQLSchemaQueries;
 import com.djrapitops.plan.storage.database.sql.tables.*;
+import com.djrapitops.plan.storage.database.sql.tables.extension.ExtensionPlayerTableValueTable;
+import com.djrapitops.plan.storage.database.sql.tables.extension.ExtensionServerTableValueTable;
 import com.djrapitops.plan.storage.database.transactions.Transaction;
 import org.apache.commons.text.TextStringBuilder;
 
@@ -66,6 +68,13 @@ protected void performOperations() {
 
         createIndex(SessionsTable.TABLE_NAME, "plan_session_join_address_index",
                 SessionsTable.JOIN_ADDRESS_ID);
+
+        createIndex(ExtensionPlayerTableValueTable.TABLE_NAME, "plan_extension_player_table_value_player_index",
+                ExtensionPlayerTableValueTable.TABLE_ID,
+                ExtensionPlayerTableValueTable.USER_UUID);
+        createIndex(ExtensionServerTableValueTable.TABLE_NAME, "plan_extension_server_table_value_server_index",
+                ExtensionServerTableValueTable.TABLE_ID,
+                ExtensionServerTableValueTable.SERVER_UUID);
     }
 
     private void createIndex(String tableName, String indexName, String... indexedColumns) {