Add: SQLITE as storage medium Change: The MYSQL connection has been slightly optimized Fix: The command 'gui-item slot <number>' dat not set the item to the right place?pull/8/head
13 changed files with 309 additions and 67 deletions
@ -0,0 +1,135 @@
@@ -0,0 +1,135 @@
|
||||
package de.jatitv.commandguiv2.Spigot.system.database; |
||||
|
||||
import de.jatitv.commandguiv2.Spigot.Main; |
||||
import de.jatitv.commandguiv2.Util; |
||||
import net.t2code.lib.Spigot.Lib.messages.send; |
||||
import org.bukkit.Bukkit; |
||||
|
||||
import java.io.File; |
||||
import java.sql.*; |
||||
import java.util.ArrayList; |
||||
import java.util.HashMap; |
||||
|
||||
public class SQLITE { |
||||
protected static String url; |
||||
private static Connection con; |
||||
|
||||
public static void main() throws SQLException { |
||||
long long_ = System.currentTimeMillis(); |
||||
File directory = new File(Main.getPath() + "/Storage"); |
||||
if (!directory.exists()) { |
||||
directory.mkdir(); |
||||
} |
||||
url = "jdbc:sqlite:" + Main.plugin.getDataFolder() + "/Storage/data.db"; |
||||
con = DriverManager.getConnection(url); |
||||
Bukkit.getConsoleSender().sendMessage(Util.getPrefix() + " §2Datenbank erfolgreich verbunden." + " §7- §e" + (System.currentTimeMillis() - long_) + "ms"); |
||||
DatabaseMetaData dbmd = con.getMetaData(); |
||||
} |
||||
|
||||
public static void query(String query) { |
||||
|
||||
send.debug(Main.plugin, query); |
||||
try { |
||||
Statement stmt = con.createStatement(); |
||||
stmt.execute(query); |
||||
stmt.close(); |
||||
} catch (SQLException e) { |
||||
System.err.println(e.getMessage()); |
||||
} |
||||
} |
||||
|
||||
public static void query(ArrayList<String> queryList) { |
||||
try { |
||||
Statement stmt = con.createStatement(); |
||||
for (String query : queryList) { |
||||
send.debug(Main.plugin, query); |
||||
stmt.addBatch(query); |
||||
} |
||||
stmt.executeBatch(); |
||||
stmt.close(); |
||||
} catch (SQLException e) { |
||||
System.err.println(e.getMessage()); |
||||
} |
||||
} |
||||
|
||||
|
||||
public static HashMap<String, ArrayList<String>> selectAll(String query) { |
||||
send.debug(Main.plugin, query); |
||||
HashMap<String, ArrayList<String>> Result = new HashMap<>(); |
||||
try { |
||||
Statement stmt = con.createStatement(); |
||||
ResultSet rs = stmt.executeQuery(query); |
||||
int columns = rs.getMetaData().getColumnCount(); |
||||
while (rs.next()) { |
||||
ArrayList<String> columnList = new ArrayList<>(); |
||||
for (int i = 1; i <= columns; i++) { |
||||
columnList.add(rs.getString(i)); |
||||
} |
||||
Result.put(rs.getString(1), columnList); |
||||
} |
||||
rs.close(); |
||||
stmt.close(); |
||||
} catch (SQLException ex) { |
||||
System.err.println(ex.getMessage()); |
||||
} |
||||
return Result; |
||||
} |
||||
|
||||
public static String select(String query) { |
||||
send.debug(Main.plugin, query); |
||||
String Ausgabe = ""; |
||||
try { |
||||
Statement stmt = con.createStatement(); |
||||
ResultSet rs = stmt.executeQuery(query); |
||||
while (rs.next()) { |
||||
Ausgabe = String.valueOf(rs.getString(1)); |
||||
} |
||||
rs.close(); |
||||
stmt.close(); |
||||
} catch (SQLException ex) { |
||||
System.err.println(ex.getMessage()); |
||||
} |
||||
return Ausgabe; |
||||
} |
||||
|
||||
public static int count(String query) { |
||||
send.debug(Main.plugin, query); |
||||
int count = 0; |
||||
try { |
||||
Statement stmt = con.createStatement(); |
||||
ResultSet rs = stmt.executeQuery(query); |
||||
while (rs.next()) { |
||||
count++; |
||||
} |
||||
rs.close(); |
||||
stmt.close(); |
||||
} catch (SQLException ex) { |
||||
System.err.println(ex.getMessage()); |
||||
} |
||||
return count; |
||||
} |
||||
|
||||
public static ArrayList<String> selectRow(String query) { |
||||
send.debug(Main.plugin, query); |
||||
ArrayList<String> Result = new ArrayList<>(); |
||||
try { |
||||
Statement stmt = con.createStatement(); |
||||
ResultSet rs = stmt.executeQuery(query); |
||||
int columns = rs.getMetaData().getColumnCount(); |
||||
while (rs.next()) { |
||||
for (int i = 1; i <= columns; i++) { |
||||
Result.add(rs.getString(i)); |
||||
} |
||||
} |
||||
rs.close(); |
||||
stmt.close(); |
||||
} catch (SQLException ex) { |
||||
System.err.println(ex.getMessage()); |
||||
} |
||||
return Result; |
||||
} |
||||
|
||||
public static void close() throws SQLException { |
||||
if (con != null) con.close(); |
||||
} |
||||
} |
||||
Loading…
Reference in new issue