-
Notifications
You must be signed in to change notification settings - Fork 4
/
Copy pathConnector.java
127 lines (109 loc) · 4.48 KB
/
Connector.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
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
package database;
import org.hibernate.Session;
import java.sql.Connection;
import database.wrap.*;
/** êëàññ, êîòîðûé ïðîèçâîäèò ñîåäèíåíèå ñ áàçîé äàííûõ, ïîñðåäñòîì Hibernate è Connection */
@SuppressWarnings("unused")
public class Connector {
// INFO êîíòðîëåð.ìåñòî ïðèñîåäèíåíèÿ âñåõ êëàññîâ äëÿ àêòèâàöèè îòîáðàæåíèÿ îáúåêòîâ áàçû äàííûõ íà îáúåêòû ïðîãðàììû
private Class<?>[] classesOfDatabase=new Class[]{
People.class,
Rfid.class
/*Module.class,
ModuleAlarmCheckerWrap.class,
ModuleAlarmWrap.class,
ModuleHeartBeat.class,
ModuleInformationCheckerWrap.class,
ModuleInformationWrap.class,
ModuleTaskWrap.class,
ModuleSettings.class,
ModuleSettingsSection.class,
ModuleSettingsParameter.class,
ModuleSensor.class,
SensorType.class,
ModuleStorage.class,
ModuleRestart.class*/
};
private IConnector connector=null;
private HibernateConnection hibernateConnection;
public Connector() throws Exception{
this("rfid","SYSDBA","masterkey");
}
/** ïðîèçâåñòè ñîåäèíåíèå ñ áàçîé äàííûõ ïîñðåäñòâîì ôàéëà
public Connector(File file) throws Exception {
while(true){
if(file.exists()==false){
throw new IOException("file is not exists:"+file.getAbsolutePath());
}
// ïîïûòêà îïðåäåëåíèÿ Firebird
if(file.getName().toUpperCase().endsWith(".GDB")){
System.out.println("Connector created:");
try{
this.connector=new FirebirdConnection(file);
}catch(Exception ex){
}
hibernateConnection=new HibernateConnection("org.hibernate.dialect.FirebirdDialect",classOfDatabase);
break;
}
throw new Exception("algorithm is not found");
}
}
ïðîèçâåñòè ñîåäèíåíèå ñ áàçîé äàííûõ ïîñðåäñòâîì ôàéëà
public Connector(String path) throws Exception {
System.out.println("Connector created:");
this.connector=new FirebirdConnection(path);
hibernateConnection=new HibernateConnection("org.hibernate.dialect.FirebirdDialect",classOfDatabase);
}*/
/** ïðîèçâåñòè ñîåäèíåíèå ñ áàçîé äàííûõ ïîñðåäñòâîì ôàéëà*/
private Connector(String path) throws Exception {
System.out.println("Connector created:");
this.connector=new FirebirdConnection(path);
hibernateConnection=new HibernateConnection("org.hibernate.dialect.FirebirdDialect",classesOfDatabase);
//this.connector=new MySqlConnection(null,null,path,null,null);
//org.hibernate.dialect.MySQLDialect
//org.hibernate.dialect.MySQL5Dialect
//hibernateConnection=new HibernateConnection("org.hibernate.dialect.MySQL5Dialect", classesOfDatabase);
}
/** ïðîèçâåñòè ñîåäèíåíèå ñ áàçîé äàííûõ ïîñðåäñòâîì ôàéëà*/
private Connector(String path, String userName, String password) throws Exception {
System.out.println("Connector created:");
this.connector=new FirebirdConnection(path,userName, password);
hibernateConnection=new HibernateConnection("org.hibernate.dialect.FirebirdDialect",classesOfDatabase);
//this.connector=new MySqlConnection(null,null,path,userName,password);
//Connection testConnection=this.connector.getConnection();
//System.out.println("TestConnection:"+testConnection);
//org.hibernate.dialect.MySQLDialect
//org.hibernate.dialect.MySQL5Dialect
//hibernateConnection=new HibernateConnection("org.hibernate.dialect.MySQL5Dialect", classesOfDatabase);
}
/** ïîëó÷èòü Hibernate Session */
private Session openSession(Connection connection){
return this.hibernateConnection.openSession(connection);
}
/** ïîëó÷èòü ñîåäèíåíèå ñ áàçîé äàííûõ */
private Connection getConnection(){
return this.connector.getConnection();
}
public ConnectWrap getConnector(){
Connection connection=this.getConnection();
Session session=this.openSession(connection);
return new ConnectWrap(connection,session);
}
/*
public static void main(String[] args) throws Exception {
System.out.println("-- begin --");
Connector connector=new Connector("fenomen","root","root");
System.out.println("Connector: "+connector.getConnector());
System.out.println("-- end --");
Connection connection=connector.getConnection();
DatabaseMetaData metaData=connection.getMetaData();
ResultSet rs=metaData.getClientInfoProperties();
int columnCount=rs.getMetaData().getColumnCount();
while(rs.next()){
for(int counter=0;counter<columnCount;counter++){
System.out.print(counter+" : "+rs.getString(counter));
}
System.out.println();
}
}*/
}