Update work with database and refactor
This commit is contained in:
@@ -10,8 +10,8 @@
|
|||||||
</parent>
|
</parent>
|
||||||
<groupId>com.Samsung</groupId>
|
<groupId>com.Samsung</groupId>
|
||||||
<artifactId>TaskTraker_Server</artifactId>
|
<artifactId>TaskTraker_Server</artifactId>
|
||||||
<version>0.0.1-SNAPSHOT</version>
|
<version>0.1.0</version>
|
||||||
<name>TaskTraker_Server</name>
|
<name>TaskTracker_Server</name>
|
||||||
<description>Demo project for Spring Boot</description>
|
<description>Demo project for Spring Boot</description>
|
||||||
<url/>
|
<url/>
|
||||||
<licenses>
|
<licenses>
|
||||||
|
|||||||
@@ -28,14 +28,12 @@ public class DataBase {
|
|||||||
private static DataBase instance;
|
private static DataBase instance;
|
||||||
private final Connection connection;
|
private final Connection connection;
|
||||||
private final List<TaskDB> TaskDBList = new ArrayList<>();
|
private final List<TaskDB> TaskDBList = new ArrayList<>();
|
||||||
private final List<User> DataBaseCache = new ArrayList<>();
|
|
||||||
private final Timer UpdateDBTimer = new Timer();
|
private final Timer UpdateDBTimer = new Timer();
|
||||||
|
|
||||||
public void close() {
|
public void close() {
|
||||||
UpdateDBTimer.cancel();
|
UpdateDBTimer.cancel();
|
||||||
for (TaskDB i : TaskDBList)
|
for (TaskDB i : TaskDBList)
|
||||||
i.execute();
|
i.execute();
|
||||||
DataBaseCache.clear();
|
|
||||||
TaskDBList.clear();
|
TaskDBList.clear();
|
||||||
try {
|
try {
|
||||||
connection.close();
|
connection.close();
|
||||||
@@ -58,7 +56,6 @@ public class DataBase {
|
|||||||
public void run() {
|
public void run() {
|
||||||
for (TaskDB i : TaskDBList)
|
for (TaskDB i : TaskDBList)
|
||||||
i.execute();
|
i.execute();
|
||||||
DataBaseCache.clear();
|
|
||||||
TaskDBList.clear();
|
TaskDBList.clear();
|
||||||
}
|
}
|
||||||
}, 1_800_000,1_800_000);
|
}, 1_800_000,1_800_000);
|
||||||
@@ -99,8 +96,7 @@ public class DataBase {
|
|||||||
saveUser_stmt.setString(1, user.getLogin());
|
saveUser_stmt.setString(1, user.getLogin());
|
||||||
saveUser_stmt.setString(2, user.getPassword());
|
saveUser_stmt.setString(2, user.getPassword());
|
||||||
saveUser_stmt.setString(3, Serialize(user.getTaskList()));
|
saveUser_stmt.setString(3, Serialize(user.getTaskList()));
|
||||||
TaskDBList.add(new TaskDB(saveUser_stmt));
|
saveUser_stmt.executeUpdate();
|
||||||
DataBaseCache.add(user);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public void UpdateTaskList(User user) throws SQLException {
|
public void UpdateTaskList(User user) throws SQLException {
|
||||||
@@ -111,10 +107,6 @@ public class DataBase {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public User FindUser(String login) throws SQLException {
|
public User FindUser(String login) throws SQLException {
|
||||||
for (User i : DataBaseCache) {
|
|
||||||
if(i.getLogin().equals(login))
|
|
||||||
return i;
|
|
||||||
}
|
|
||||||
|
|
||||||
PreparedStatement getUser_stmt = connection.prepareStatement("SELECT * FROM user WHERE login = ?");
|
PreparedStatement getUser_stmt = connection.prepareStatement("SELECT * FROM user WHERE login = ?");
|
||||||
getUser_stmt.setString(1, login);
|
getUser_stmt.setString(1, login);
|
||||||
|
|||||||
Reference in New Issue
Block a user