TBQmcGba

1package sleiferhd.core.config;
2
3import java.sql.ResultSet;
4import java.sql.SQLException;
5
6public class Mysql {
7	
8	private final MysqlConnection mysql;
9	
10	protected Mysql(MysqlConnection mysql)
11	{
12		this.mysql = mysql;
13	}
14	
15	public void createTableIfNotExists(String tableName, String[] keys, String[] keyTypes)
16	{
17		String cmd = "CREATE TABLE IF NOT EXISTS " + tableName + " (";
18		for(int i = 0; i < keys.length; i ++)
19		{
20			if(i > 0)
21				cmd += ", ";
22			cmd += keys[i] + " " + keyTypes[i];
23		}
24		cmd += ")";
25		mysql.executeUpdate(cmd);
26	}
27	
28	public void setDefaultValues(String tableName, String keyName, String keyValue, String keys, String values)
29	{
30		ResultSet set = get(tableName, keyName, keyValue);
31		try {
32			if(set != null && set.next())
33				return;
34		} catch(SQLException err) {err.printStackTrace();}
35		String cmd = "INSERT INTO " + tableName + " (" + keys + ") VALUES (" + values + ")";
36		mysql.executeUpdate(cmd);
37	}
38	
39	public ResultSet get(String tableName, String keyName, String keyValue)
40	{
41		String cmd = "SELECT * FROM " + tableName + " WHERE " + keyName + "='" + keyValue + "'";
42		ResultSet set = mysql.executeQuery(cmd);
43		return set;
44	}
45	
46	public String getString(String tableName, String idKeyName, String idKeyValue, String keyName, String defaultValue)
47	{
48		ResultSet set = get(tableName, idKeyName, idKeyValue);
49		try {
50			if(set != null && set.next())
51				return set.getString(keyName);
52		} catch(SQLException err) {err.printStackTrace();}
53		return defaultValue;
54	}
55	
56	public int getInteger(String tableName, String idKeyName, String idKeyValue, String keyName, int defaultValue)
57	{
58		ResultSet set = get(tableName, idKeyName, idKeyValue);
59		try {
60			if(set != null && set.next())
61				return set.getInt(keyName);
62		} catch(SQLException err) {err.printStackTrace();}
63		return defaultValue;
64	}
65	
66	public void set(String tableName, String idKeyName, String idKeyValue, String keyName, String keyValue)
67	{
68		String cmd = "UPDATE " + tableName + " SET " + keyName + "='" + keyValue + "' WHERE " + idKeyName + "='" + idKeyValue + "'";
69		mysql.executeUpdate(cmd);
70	}
71	
72}