Upstream/bentobox
1
0
Fork 0
mirror of https://github.com/BentoBoxWorld/BentoBox.git synced 2024-08-19 03:42:50 +02:00
Code Issues Projects Releases Wiki Activity

Fixes loading of SQLite tables.

Browse Source 
Bug was affecting addons that single table entries.

https://github.com/BentoBoxWorld/BentoBox/issues/902
This commit is contained in:
tastybento 2019-08-18 17:26:08 -07:00
parent 33b4c70f25
commit c764444fa5
1 changed files with 44 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
src/main/java/world/bentobox/bentobox/database/sql/sqlite/SQLiteDatabaseHandler.java
View File

@ -1,15 +1,18 @@
package world.bentobox.bentobox.database.sql.sqlite; package world.bentobox.bentobox.database.sql.sqlite;
import java.sql.PreparedStatement; import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException; import java.sql.SQLException;
import org.eclipse.jdt.annotation.NonNull;
import com.google.gson.Gson; import com.google.gson.Gson;
import world.bentobox.bentobox.BentoBox; import world.bentobox.bentobox.BentoBox;
import world.bentobox.bentobox.database.DatabaseConnector; import world.bentobox.bentobox.database.DatabaseConnector;
import world.bentobox.bentobox.database.objects.DataObject; import world.bentobox.bentobox.database.objects.DataObject;
import world.bentobox.bentobox.database.sql.SQLDatabaseHandler;
import world.bentobox.bentobox.database.sql.SQLConfiguration; import world.bentobox.bentobox.database.sql.SQLConfiguration;
import world.bentobox.bentobox.database.sql.SQLDatabaseHandler;
/** /**
* @since 1.6.0 * @since 1.6.0
@ -17,6 +20,8 @@ import world.bentobox.bentobox.database.sql.SQLConfiguration;
*/ */
public class SQLiteDatabaseHandler<T> extends SQLDatabaseHandler<T> { public class SQLiteDatabaseHandler<T> extends SQLDatabaseHandler<T> {
private static final String COULD_NOT_LOAD_OBJECT = "Could not load object ";
/** /**
* Constructor * Constructor
* *
@ -73,4 +78,42 @@ public class SQLiteDatabaseHandler<T> extends SQLDatabaseHandler<T> {
} }
}); });
} }
@Override
public boolean objectExists(String uniqueId) {
// Query to see if this key exists
try (PreparedStatement preparedStatement = getConnection().prepareStatement(getSqlConfig().getObjectExistsSQL())) {
// UniqueId needs to be placed in quotes
preparedStatement.setString(1, uniqueId);
try (ResultSet resultSet = preparedStatement.executeQuery()) {
if (resultSet.next()) {
return resultSet.getBoolean(1);
}
}
} catch (SQLException e) {
plugin.logError("Could not check if key exists in database! " + uniqueId + " " + e.getMessage());
}
return false;
}
@Override
public T loadObject(@NonNull String uniqueId) {
try (PreparedStatement preparedStatement = getConnection().prepareStatement(getSqlConfig().getLoadObjectSQL())) {
// UniqueId needs to be placed in quotes
preparedStatement.setString(1, uniqueId);
try (ResultSet resultSet = preparedStatement.executeQuery()) {
if (resultSet.next()) {
// If there is a result, we only want/need the first one
Gson gson = getGson();
return gson.fromJson(resultSet.getString("json"), dataObject);
}
} catch (Exception e) {
plugin.logError(COULD_NOT_LOAD_OBJECT + uniqueId + " " + e.getMessage());
}
} catch (SQLException e) {
plugin.logError(COULD_NOT_LOAD_OBJECT + uniqueId + " " + e.getMessage());
}
return null;
}
} }