Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public class HelperSQL {
- public static Connection conn;
- public static void registerHelper(String p){
- ResultSet rs = executeQuery("SELECT PlayerName FROM helpersql WHERE PlayerName='" + p + "'");
- try {
- if(!rs.next()){
- executeUpdate("INSERT INTO helpersql (PlayerName,PlayerTotalTime,PlayerJoinTime,1,2,3,4,5,6,7) VALUES ('" + p + "',0,0,0,0,0,0,0,0,0)");
- }
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- public static void connect(String host,Integer port,String USER,String PASS,String DB_NAME){
- String DB = "jdbc:mysql://" + host + ":" + port + "/" +DB_NAME;
- try {
- Class.forName("com.mysql.jdbc.Driver");
- Bukkit.getLogger().info("About to connect to database");
- conn = DriverManager.getConnection(DB + "?autoReconnect=true", USER, PASS);
- Bukkit.getLogger().info("Successfully connected.");
- conn.createStatement();
- }catch(SQLException e){
- e.printStackTrace();
- }catch(ClassNotFoundException e) {
- e.printStackTrace();
- }
- }
- public static Statement createStatement(){
- Statement s=null;
- try {
- s = conn.createStatement();
- } catch (SQLException e) {
- e.printStackTrace();
- }
- return s;
- }
- public static void closeConnection() {
- try {
- if( conn != null && !conn.isClosed() ) {
- conn.close();
- }
- } catch (SQLException e) {
- e.printStackTrace();
- }
- }
- public static ResultSet executeQuery(String q){
- ResultSet rs = null;
- try {
- rs = createStatement().executeQuery(q);
- } catch (SQLException e) {
- e.printStackTrace();
- Bukkit.getLogger().warning("[Coins] Error occured while trying to execute query: \"" + q + "\"");
- }
- return rs;
- }
- public static void executeUpdate(String u){
- try {
- createStatement().executeUpdate(u);
- } catch (SQLException e) {
- e.printStackTrace();
- Bukkit.getLogger().warning("[Coins] Error occured while trying to execute update: \"" + u + "\"");
- }
- }
- public static void updateData(String table, String newData, String conditions){
- executeUpdate("UPDATE " + table + " SET " + newData + " WHERE " + conditions);
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement