-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathDBOperation.java
92 lines (74 loc) · 2.19 KB
/
DBOperation.java
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
92
package dao;
import java.util.List;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import org.hibernate.cfg.AnnotationConfiguration;
public class DBOperation {
static AnnotationConfiguration annotationConfiguration;
static SessionFactory sessionFactory;
Session session;
Transaction transaction;
Query query;
List list;
static {
annotationConfiguration = new AnnotationConfiguration();
annotationConfiguration.configure("hibernate.cfg.xml");
sessionFactory = annotationConfiguration.buildSessionFactory();
}
public List getListByParams(String hqlQuery, String[] paramNames, String[] paramValues) {
query = session.createQuery(hqlQuery);
if(paramNames.length == paramValues.length)
{
for(int i=0;i<paramNames.length;i++)
query.setParameter(paramNames[i], paramValues[i]);
}
else
return null;
return query.list();
}
public void openSession() {
session = sessionFactory.openSession();
}
public void closeSession() {
session.close();
}
public void openSessionWithTransaction() {
session = sessionFactory.openSession();
transaction = session.beginTransaction();
}
public void closeSessionWithTransaction() {
transaction.commit();
session.close();
}
public List getList(String hqlQuery) {
// first call openSession
query = session.createQuery(hqlQuery);
return query.list();
}
public void insert(Object commonVo) {
session.save(commonVo);
}
public void update(Object commonVo) {
session.update(commonVo);
}
public void updateQuery(String hqlQuery) {
query = session.createQuery(hqlQuery);
query.executeUpdate();
}
public void delete(String hqlQuery) {
query = session.createQuery(hqlQuery);
query.executeUpdate();
}
public void delete(Object commonVo) {
session.delete(commonVo);
}
public List getListByParam(String hqlQuery, String masterEmail, String masterPassword, String param1,
String param2) {
query = session.createQuery(hqlQuery);
query.setParameter(param1, masterEmail);
query.setParameter(param2, masterPassword);
return query.list();
}
}