Skip to content

Commit 947cab9

Browse files
committed
Add new proxy mysql interface
1 parent 88977e3 commit 947cab9

File tree

3 files changed

+73
-3
lines changed

3 files changed

+73
-3
lines changed

AdvancedCore/src/com/bencodez/advancedcore/bungeeapi/mysql/BungeeMySQL.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525
import net.md_5.bungee.api.plugin.Plugin;
2626
import net.md_5.bungee.config.Configuration;
2727

28-
public abstract class BungeeMySQL {
28+
public abstract class BungeeMySQL implements ProxyMySQL {
2929
private List<String> columns = Collections.synchronizedList(new ArrayList<String>());
3030

3131
private List<String> intColumns = new ArrayList<>();
Lines changed: 70 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,70 @@
1+
package com.bencodez.advancedcore.bungeeapi.mysql;
2+
3+
import java.sql.SQLException;
4+
import java.util.ArrayList;
5+
import java.util.List;
6+
import java.util.Set;
7+
import java.util.UUID;
8+
import java.util.concurrent.ConcurrentHashMap;
9+
10+
import com.bencodez.advancedcore.api.user.usercache.value.DataValue;
11+
import com.bencodez.advancedcore.api.user.userstorage.Column;
12+
import com.bencodez.advancedcore.api.user.userstorage.DataType;
13+
14+
public interface ProxyMySQL {
15+
void addColumn(String column, DataType dataType);
16+
17+
void alterColumnType(String column, String newType);
18+
19+
void checkColumn(String column, DataType dataType);
20+
21+
void clearCache();
22+
23+
void close();
24+
25+
com.bencodez.advancedcore.api.user.userstorage.mysql.api.MySQL getMysql();
26+
27+
boolean containsKeyQuery(String index);
28+
29+
void copyColumnData(String columnFromName, String columnToName);
30+
31+
void debug(SQLException e);
32+
33+
List<String> getColumns();
34+
35+
ArrayList<String> getColumnsQueury();
36+
37+
ArrayList<Column> getExactQuery(Column column);
38+
39+
String getName();
40+
41+
ArrayList<String> getNamesQuery();
42+
43+
ArrayList<Column> getRowsNameQuery();
44+
45+
ArrayList<Column> getRowsQuery();
46+
47+
ConcurrentHashMap<UUID, String> getRowsUUIDNameQuery();
48+
49+
String getUUID(String playerName);
50+
51+
Set<String> getUuids();
52+
53+
ArrayList<String> getUuidsQuery();
54+
55+
void insert(String index, String column, DataValue value);
56+
57+
void insertQuery(String index, List<Column> cols);
58+
59+
boolean isIntColumn(String key);
60+
61+
void loadData();
62+
63+
void update(String index, List<Column> cols);
64+
65+
void update(String index, String column, DataValue value);
66+
67+
void wipeColumnData(String columnName, DataType dataType);
68+
69+
void shutdown();
70+
}

AdvancedCore/src/com/bencodez/advancedcore/bungeeapi/mysql/VelocityMySQL.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424

2525
import lombok.Getter;
2626

27-
public abstract class VelocityMySQL {
27+
public abstract class VelocityMySQL implements ProxyMySQL {
2828
private List<String> columns = Collections.synchronizedList(new ArrayList<String>());
2929

3030
private List<String> intColumns = new ArrayList<>();
@@ -446,7 +446,7 @@ public void loadData() {
446446

447447
public abstract void severe(String str);
448448

449-
public void shutDown() {
449+
public void shutdown() {
450450
mysql.disconnect();
451451
}
452452

0 commit comments

Comments
 (0)