Не кидать тапками.
Я создавал тему подобную уже. Но не хочется писать там ибо много сообщений.
Я постараюсь описать все от а до я что бы не было кучи лишних вопросов и прочего, одним словом срача.
Итак. Я не использую никакие фреймворки, ОРМ и прочее - все пишется ручками (используются либы). Почему так? Поясняю - Проект начинал писаться без этого всего и сейчас, когда он уже почти готов и в нем просто дофига функционала, переписывать никто не будет ибо а) нет на это времени и б) нет средств. По сему, пожалуйста, не надо про это писать. Я знаю как сейчас делается, но причину по которой переделываться не будет я озвучил.
Есть класс DataSource (Синглтон). Предоставляется библиотекой Commons dbcp2. Служит для пула подключений (при старте приложения создаётся 10 подключений к бд и хранятся в BasicDataSource).
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
public class DataSource {
private static final DataSource INSTANCE = new DataSource();
private final BasicDataSource basicDataSource = new BasicDataSource();
private DataSource() {
try {
basicDataSource.setDriverClassName("com.mysql.jdbc.Driver");
basicDataSource.setUrl("jdbc:mysql://localhost:3306/db");
basicDataSource.setUsername("root");
basicDataSource.setPassword("root");
basicDataSource.setInitialSize(10);
basicDataSource.setMaxWaitMillis(180000);
basicDataSource.setDefaultAutoCommit(true);
basicDataSource.setPoolPreparedStatements(true);
basicDataSource.setConnectionProperties("useUnicode=true;characterEncoding=utf8");
QueryRunner queryRunner = new QueryRunner(basicDataSource);
queryRunner.update("SET GLOBAL sql_mode='STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION';");
queryRunner.update("SET SESSION sql_mode='STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION';");
} catch (Exception e) {
}
}
public static DataSource getInstance() {
return INSTANCE;
}
public BasicDataSource getDataSource() {
return basicDataSource;
}
public static JSONObject getDbResultObject(ResultSet rs) throws SQLException {
JSONObject result = new JSONObject();
int index = 0;
while(rs.next()) {
result.put(index, getDbRow(rs));
index++;
}
return result;
}
public static JSONArray getDbResultArray(ResultSet rs) throws SQLException {
JSONArray result = new JSONArray();
while(rs.next()) {
result.add(getDbRow(rs));
}
return result;
}
public static JSONObject getDbSingleRow(ResultSet rs) throws SQLException {
return rs.next()? getDbRow(rs): new JSONObject();
}
private static JSONObject getDbRow(ResultSet rs) throws SQLException {
JSONObject result = new JSONObject();
ResultSetMetaData meta = rs.getMetaData();
for(int i=0;i<meta.getColumnCount();i++) {
Object obj = rs.getObject(i+1);
if(obj instanceof Time) {
String date = TIME_FORMAT.format((java.util.Date) obj);
result.put(meta.getColumnLabel(i+1), date);
} else if(obj instanceof Timestamp) {
String date = DATE_TIME_FORMAT.format((java.util.Date) obj);
result.put(meta.getColumnLabel(i+1), date);
} else if(obj instanceof java.util.Date) {
String date = DATE_FORMAT.format((java.util.Date) obj);
result.put(meta.getColumnLabel(i+1), date);
} else {
result.put(meta.getColumnLabel(i+1), rs.getObject(i+1)==null?"":obj);
}
}
return result;
}
}
Далее.
Есть классы в которых прописаны запросы к бд. Это не синглтоны.
Их всего 3:
DataBaseUser(Запрос которые отвечают за пользователя),
DataBaseAdmin(Запросы которые относятся к внутреннему функционалу проекта),
DataBaseChat (Запросы которые относятся к чату)
Я специально разделил эти запросы: Все запросы относятся только к той области где они применяются. К примеру DataBaseChat обслуживает чат.
Код DataBaseAdmin:
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
public class DataBaseAdmin {
private QueryRunner queryRunner;
public DataBaseUser(BasicDataSource basicDataSource) {
this.queryRunner = new QueryRunner(basicDataSource);
}
// Примеры запросов
public JSONArray userGetPayments(int userId, boolean paid, boolean active, boolean wait, boolean finish, boolean activate) throws SQLException {
return getQueryRunner().query("SELECT p.*, s.id AS site_id, url FROM payments AS p LEFT JOIN site AS s ON s.id=p.site_id WHERE p.user_id = ? AND p.paid = ? AND active = ? AND wait = ? AND finish = ? AND (activate = ? OR activate = ?);", new ResultSetHandler<JSONArray>() {
public JSONArray handle(ResultSet rs) throws SQLException {
return DataSource.getDbResultArray(rs);
}
}, userId, paid, active, wait, finish, activate, !activate);
}
public JSONObject userGetInfo(int userId) throws SQLException {
return getQueryRunner().query(SqlCore.SQL_USER_INFO_GET, new ResultSetHandler<JSONObject>() {
public JSONObject handle(ResultSet rs) throws SQLException {
return DataSource.getDbSingleRow(rs);
}
}, userId);
}
public int paymentAdd(Payment pm) throws SQLException {
return getQueryRunner().insert(SqlCore.SQL_PAYMENT_ADD, new ScalarHandler<Long>(), pm.getUserId(), pm.getSiteId(), pm.getRateId(), pm.getStart(), pm.getEnd(), pm.isPaid(), pm.isActive(), pm.isWait(), pm.isFinish(), pm.isActivate()).intValue();
}
public boolean paymentUpdate(Payment pm) throws SQLException {
return getQueryRunner().update(SqlCore.SQL_PAYMENT_UPDATE, pm.getUserId(), pm.getSiteId(), pm.getRateId(), pm.getStart(), pm.getEnd(), pm.isPaid(), pm.isActive(), pm.isWait(), pm.isFinish(), pm.isActivate(), pm.isError(), pm.getMessage(), pm.getId())>0;
}
}
Остальные два класса похожи конструктором и полем - все остальное разное.
Тут прописаны все запросы. В каждой выборке могут быть своя обработка результата. Запросы бывают 3 типов: QUERY, INSERT, UPDATE.
Сами запросы я делаю при помощи библиотеки Commons DbUtils - QuerryRunner. Ему передаётся BasicDataSource из которого достаётся Connection.
Использование этих классов:
1.
2.
3.
4.
BasicDataSource BDS = Core.getDataSource();
DataBaseUser dbUser = new DataBaseUser(BDS);
DataBaseAdmin dbAdmin = new DataBaseAdmin(BDS);
Где мне нужно обратиться к базе я создаю экземпляры классов у которых есть методы. Вызываю нужные методы. После окончания работы с бд я выполняю возврат подключения в пул:
1.
BDS.getConnection().close();
Вот такая вот система. Знаю не очень удобно и красиво.
Теперь вопрос.
Как можно это все сжать или скомпоновать что бы имея один класс получать доступ ко всем методам классов. Приведу пример использования:
1.
2.
3.
4.
5.
DataBase db = new DataBase(getDataSource());
db.getDbUser().getUserIdByHash(user.getHash())
db.close();
Пример самого класса DataBase:
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
public class DataBase {
private DataBaseUser dbUser;
private DataBaseAdmin dbAdmin;
private DataBaseChat dbChat;
private QueryRunner queryRunner;
public DataBase(BasicDataSource basicDataSource) {
queryRunner = new QueryRunner(basicDataSource);
dbUser = new DataBaseUser(queryRunner);
dbAdmin = new DataBaseAdmin(queryRunner);
dbChat = new DataBaseChat(queryRunner);
}
public DataBaseUser getDbUser() {
return dbUser;
}
public DataBaseAdmin getDbAdmin() {
return dbAdmin;
}
public DataBaseChat getDbChat() {
return dbChat;
}
public void close() throws SQLException {
queryRunner.getDataSource().getConnection().close();
}
}
Может есть более элегантный вариант?
Спасибо за внимание!
