Skip to content

Commit b047607

Browse files
TalexDreamSoulTalexDreamSoul
committed
@initial MysqlDAO
1 parent 7f8217e commit b047607

42 files changed

Lines changed: 1283 additions & 760 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎.github/en/README.md‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
# TalexFrame
22

3-
[简体中文](./../../) | English
3+
[简体中文](./../../README.md) | English
44

55
```
66
/__ ___/ // / /

‎src/main/java/com/talex/talexframe/frame/config/MysqlConfig.java‎

Lines changed: 40 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package com.talex.talexframe.frame.config;
22

3-
import com.talex.talexframe.frame.core.modules.mysql.core.MysqlInfo;
3+
import com.talex.talexframe.frame.core.pojo.dao.interfaces.IProcessorConfig;
4+
import lombok.Getter;
45
import org.springframework.beans.factory.annotation.Value;
56
import org.springframework.context.annotation.Configuration;
67

@@ -11,27 +12,9 @@
1112
* @date 2022/1/21 15:48 <br /> Project: TalexFrame <br />
1213
*/
1314
@Configuration
14-
public class MysqlConfig {
15-
16-
private static MysqlInfo MYSQL_INFO;
17-
18-
public static MysqlInfo getInfo() {
19-
20-
if( MYSQL_INFO == null ) {
21-
22-
MYSQL_INFO = new MysqlInfo()
23-
.setIp(instance.ip).setPort(instance.port)
24-
.setDatabaseName(instance.database)
25-
.setPassword(instance.password)
26-
.setUsername(instance.username)
27-
.setUseSSL(instance.useSSL);
28-
29-
}
30-
31-
return MYSQL_INFO;
32-
33-
}
15+
public class MysqlConfig implements IProcessorConfig {
3416

17+
@Getter
3518
private static MysqlConfig instance;
3619

3720
public MysqlConfig() {
@@ -58,4 +41,40 @@ public MysqlConfig() {
5841
@Value("${mysql.useSSL}")
5942
private boolean useSSL;
6043

44+
@Override
45+
public String getIpAddress() {
46+
47+
return ip;
48+
}
49+
50+
@Override
51+
public int getPort() {
52+
53+
return port;
54+
}
55+
56+
@Override
57+
public String getDatabaseName() {
58+
59+
return database;
60+
}
61+
62+
@Override
63+
public String getUsername() {
64+
65+
return username;
66+
}
67+
68+
@Override
69+
public String getPassword() {
70+
71+
return password;
72+
}
73+
74+
@Override
75+
public String getExtra() {
76+
77+
return "?autoReconnect=true&serverTimezone=Asia/Shanghai&useSSL=" + useSSL;
78+
}
79+
6180
}

‎src/main/java/com/talex/talexframe/frame/core/function/listener/FrameSelfListener.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,8 @@
22

33
import com.talex.talexframe.frame.core.modules.event.FrameListener;
44
import com.talex.talexframe.frame.core.modules.event.TalexSubscribe;
5-
import com.talex.talexframe.frame.core.modules.event.events.mysql.MysqlConnectedEvent;
6-
import com.talex.talexframe.frame.core.modules.event.events.mysql.MysqlPreShutdownEvent;
5+
import com.talex.talexframe.frame.core.modules.event.events.dao.DAOProcessorConnectedEvent;
6+
import com.talex.talexframe.frame.core.modules.event.events.dao.DAOProcessorPreShutdownEvent;
77
import com.talex.talexframe.frame.core.modules.repository.TAutoRepository;
88
import com.talex.talexframe.frame.core.modules.repository.TRepository;
99
import com.talex.talexframe.frame.core.talex.TFrame;
@@ -25,7 +25,7 @@ public FrameSelfListener() {
2525
}
2626

2727
@TalexSubscribe
28-
public void onMysqlConnected(MysqlConnectedEvent event) {
28+
public void onMysqlConnected(DAOProcessorConnectedEvent event) {
2929

3030
for( TRepository repository : tframe.getRepositoryManager().getRepositories().values() ) {
3131

@@ -40,7 +40,7 @@ public void onMysqlConnected(MysqlConnectedEvent event) {
4040
}
4141

4242
@TalexSubscribe
43-
public void onMysqlPreShutdown(MysqlPreShutdownEvent event) {
43+
public void onMysqlPreShutdown(DAOProcessorPreShutdownEvent event) {
4444

4545
for( TRepository repository : tframe.getRepositoryManager().getRepositories().values() ) {
4646

src/main/java/com/talex/talexframe/frame/core/modules/event/events/mysql/MysqlConnectFailedEvent.java renamed to src/main/java/com/talex/talexframe/frame/core/modules/event/events/dao/DAOProcessorConnectFailedEvent.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
1-
package com.talex.talexframe.frame.core.modules.event.events.mysql;
1+
package com.talex.talexframe.frame.core.modules.event.events.dao;
22

33
import com.talex.talexframe.frame.core.modules.event.Cancellable;
44
import com.talex.talexframe.frame.core.modules.event.IContinue;
55
import com.talex.talexframe.frame.core.modules.event.TalexEvent;
6-
import com.talex.talexframe.frame.core.modules.mysql.MysqlManager;
6+
import com.talex.talexframe.frame.core.pojo.dao.interfaces.IDataProcessor;
77
import lombok.AccessLevel;
88
import lombok.Getter;
99
import lombok.Setter;
@@ -16,14 +16,14 @@
1616
*/
1717
@Getter
1818
@Setter
19-
public class MysqlConnectFailedEvent extends TalexEvent implements Cancellable, IContinue {
19+
public class DAOProcessorConnectFailedEvent extends TalexEvent implements Cancellable, IContinue {
2020

21-
private final MysqlManager mysqlManager;
21+
private final IDataProcessor processor;
2222
private final Exception e;
2323

24-
public MysqlConnectFailedEvent(MysqlManager mysqlManager, Exception e) {
24+
public DAOProcessorConnectFailedEvent(IDataProcessor processor, Exception e) {
2525

26-
this.mysqlManager = mysqlManager;
26+
this.processor = processor;
2727
this.e = e;
2828

2929
}

src/main/java/com/talex/talexframe/frame/core/modules/event/events/mysql/MysqlConnectedEvent.java renamed to src/main/java/com/talex/talexframe/frame/core/modules/event/events/dao/DAOProcessorConnectedEvent.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
1-
package com.talex.talexframe.frame.core.modules.event.events.mysql;
1+
package com.talex.talexframe.frame.core.modules.event.events.dao;
22

33
import com.talex.talexframe.frame.core.modules.event.IContinue;
44
import com.talex.talexframe.frame.core.modules.event.TalexEvent;
5-
import com.talex.talexframe.frame.core.modules.mysql.MysqlManager;
5+
import com.talex.talexframe.frame.core.pojo.dao.interfaces.IDataProcessor;
66
import lombok.AllArgsConstructor;
77
import lombok.Getter;
88
import lombok.Setter;
@@ -16,14 +16,14 @@
1616
@Getter
1717
@Setter
1818
@AllArgsConstructor
19-
public class MysqlConnectedEvent extends TalexEvent implements IContinue {
19+
public class DAOProcessorConnectedEvent extends TalexEvent implements IContinue {
2020

21-
private final MysqlManager mysqlManager;
21+
private final IDataProcessor processor;
2222

2323
@Override
2424
public String getMatchKey() {
2525

26-
return System.nanoTime() + " # MysqlConnected @" + this.hashCode();
26+
return System.nanoTime() + " # DAOProcessorConnectedEvent @" + this.hashCode();
2727
}
2828

2929
}

‎src/main/java/com/talex/talexframe/frame/core/modules/event/events/dao/DAOProcessorPostCheckStatusEvent.java‎

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
package com.talex.talexframe.frame.core.modules.event.events.dao;
2+
3+
import com.talex.talexframe.frame.core.modules.event.TalexEvent;
4+
import com.talex.talexframe.frame.core.pojo.dao.interfaces.IDataProcessor;
5+
import lombok.Getter;
6+
7+
/**
8+
* <br /> {@link com.talex.frame.talexframe.function.event.events.mysql Package }
9+
*
10+
* @author TalexDreamSoul
11+
* @date 2022/1/29 23:52 <br /> Project: TalexFrame <br />
12+
*/
13+
public class DAOProcessorPostCheckStatusEvent extends TalexEvent {
14+
15+
@Getter
16+
private final IDataProcessor processor;
17+
18+
public DAOProcessorPostCheckStatusEvent(IDataProcessor processor) {
19+
20+
this.processor = processor;
21+
22+
}
23+
24+
}

src/main/java/com/talex/talexframe/frame/core/modules/event/events/mysql/MysqlPreCheckStatusEvent.java renamed to src/main/java/com/talex/talexframe/frame/core/modules/event/events/dao/DAOProcessorPreCheckStatusEvent.java

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,9 @@
1-
package com.talex.talexframe.frame.core.modules.event.events.mysql;
1+
package com.talex.talexframe.frame.core.modules.event.events.dao;
22

33
import com.talex.talexframe.frame.core.modules.event.Cancellable;
44
import com.talex.talexframe.frame.core.modules.event.TalexEvent;
55
import com.talex.talexframe.frame.core.modules.mysql.MysqlManager;
6+
import com.talex.talexframe.frame.core.pojo.dao.interfaces.IDataProcessor;
67
import lombok.Getter;
78

89
/**
@@ -11,14 +12,14 @@
1112
* @author TalexDreamSoul
1213
* @date 2022/1/29 23:50 <br /> Project: TalexFrame <br />
1314
*/
14-
public class MysqlPreCheckStatusEvent extends TalexEvent implements Cancellable {
15+
public class DAOProcessorPreCheckStatusEvent extends TalexEvent implements Cancellable {
1516

1617
@Getter
17-
private final MysqlManager mysql;
18+
private final IDataProcessor processor;
1819

19-
public MysqlPreCheckStatusEvent(MysqlManager mysql) {
20+
public DAOProcessorPreCheckStatusEvent(IDataProcessor processor) {
2021

21-
this.mysql = mysql;
22+
this.processor = processor;
2223

2324
}
2425

src/main/java/com/talex/talexframe/frame/core/modules/event/events/mysql/MysqlPreShutdownEvent.java renamed to src/main/java/com/talex/talexframe/frame/core/modules/event/events/dao/DAOProcessorPreShutdownEvent.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
1-
package com.talex.talexframe.frame.core.modules.event.events.mysql;
1+
package com.talex.talexframe.frame.core.modules.event.events.dao;
22

33
import com.talex.talexframe.frame.core.modules.event.Cancellable;
44
import com.talex.talexframe.frame.core.modules.event.TalexEvent;
5-
import com.talex.talexframe.frame.core.modules.mysql.MysqlManager;
5+
import com.talex.talexframe.frame.core.pojo.dao.interfaces.IDataProcessor;
66
import lombok.Getter;
77

88
/**
@@ -12,15 +12,15 @@
1212
* @date 2022/1/21 15:44 <br /> Project: TalexFrame <br />
1313
*/
1414
@Getter
15-
public class MysqlPreShutdownEvent extends TalexEvent implements Cancellable {
15+
public class DAOProcessorPreShutdownEvent extends TalexEvent implements Cancellable {
1616

17-
private final MysqlManager mysqlManager;
17+
private final IDataProcessor processor;
1818

1919
private boolean cancel;
2020

21-
public MysqlPreShutdownEvent(MysqlManager manager) {
21+
public DAOProcessorPreShutdownEvent(IDataProcessor processor) {
2222

23-
this.mysqlManager = manager;
23+
this.processor = processor;
2424

2525
}
2626

src/main/java/com/talex/talexframe/frame/core/modules/event/events/mysql/package-info.java renamed to src/main/java/com/talex/talexframe/frame/core/modules/event/events/dao/package-info.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,4 +5,4 @@
55
* @author TalexDreamSoul
66
* @date 2022/1/21 15:35 <br /> Project: TalexFrame <br />
77
*/
8-
package com.talex.talexframe.frame.core.modules.event.events.mysql;
8+
package com.talex.talexframe.frame.core.modules.event.events.dao;

‎src/main/java/com/talex/talexframe/frame/core/modules/event/events/mysql/MysqlPostCheckStatusEvent.java‎

Lines changed: 0 additions & 24 deletions
This file was deleted.

0 commit comments

Comments
 (0)