|
|
|
|
@ -112,10 +112,20 @@ CREATE TABLE IF NOT EXISTS {0} (
@@ -112,10 +112,20 @@ CREATE TABLE IF NOT EXISTS {0} (
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void delete(Task task) throws UmbrellaException { |
|
|
|
|
try { |
|
|
|
|
Query.delete().from(TABLE_TASKS).where(ID,equal(task.id())).execute(db); |
|
|
|
|
Query.delete().from(TABLE_TASKS_USERS).where(TASK_ID,equal(task.id())).execute(db); |
|
|
|
|
} catch (SQLException e) { |
|
|
|
|
throw new UmbrellaException("Failed to delete task"); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void dropMember(long projectId, long userId) { |
|
|
|
|
try { |
|
|
|
|
delete().from(TABLE_TASKS_USERS) |
|
|
|
|
Query.delete().from(TABLE_TASKS_USERS) |
|
|
|
|
.where(TASK_ID,equal(projectId)) |
|
|
|
|
.where(USER_ID,equal(userId)) |
|
|
|
|
.execute(db); |
|
|
|
|
@ -133,7 +143,7 @@ CREATE TABLE IF NOT EXISTS {0} (
@@ -133,7 +143,7 @@ CREATE TABLE IF NOT EXISTS {0} (
|
|
|
|
|
rs.close(); |
|
|
|
|
return result; |
|
|
|
|
} catch (SQLException e){ |
|
|
|
|
throw new UmbrellaException(HTTP_SERVER_ERROR,"Faailed to load task members"); |
|
|
|
|
throw new UmbrellaException("Faailed to load task members"); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@ -155,7 +165,7 @@ CREATE TABLE IF NOT EXISTS {0} (
@@ -155,7 +165,7 @@ CREATE TABLE IF NOT EXISTS {0} (
|
|
|
|
|
rs.close(); |
|
|
|
|
return tasks; |
|
|
|
|
} catch (SQLException e) { |
|
|
|
|
throw new UmbrellaException(HTTP_SERVER_ERROR,"Failed to load tasks for project ids"); |
|
|
|
|
throw new UmbrellaException("Failed to load tasks for project ids"); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@ -176,7 +186,7 @@ CREATE TABLE IF NOT EXISTS {0} (
@@ -176,7 +186,7 @@ CREATE TABLE IF NOT EXISTS {0} (
|
|
|
|
|
return tasks; |
|
|
|
|
} catch (SQLException e){ |
|
|
|
|
LOG.log(WARNING,"Failed to load tasks for project (pid: {0}, user_id: {1}",projectId,user.id(),e); |
|
|
|
|
throw new UmbrellaException(HTTP_SERVER_ERROR,"Failed to load tasks for project id"); |
|
|
|
|
throw new UmbrellaException("Failed to load tasks for project id"); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@ -196,7 +206,7 @@ CREATE TABLE IF NOT EXISTS {0} (
@@ -196,7 +206,7 @@ CREATE TABLE IF NOT EXISTS {0} (
|
|
|
|
|
return tasks; |
|
|
|
|
} catch (SQLException e){ |
|
|
|
|
LOG.log(WARNING,"Failed to load child tasks (parentTaskId: {0}, user_id: {1}",parentTaskId,user.id(),e); |
|
|
|
|
throw new UmbrellaException(HTTP_SERVER_ERROR,"Failed to load tasks for project id"); |
|
|
|
|
throw new UmbrellaException("Failed to load tasks for project id"); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@ -214,7 +224,7 @@ CREATE TABLE IF NOT EXISTS {0} (
@@ -214,7 +224,7 @@ CREATE TABLE IF NOT EXISTS {0} (
|
|
|
|
|
rs.close(); |
|
|
|
|
return tasks; |
|
|
|
|
} catch (SQLException e){ |
|
|
|
|
throw new UmbrellaException(HTTP_SERVER_ERROR,"Failed to load tasks for project {0}",projectId); |
|
|
|
|
throw new UmbrellaException("Failed to load tasks for project {0}",projectId); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@ -228,7 +238,7 @@ CREATE TABLE IF NOT EXISTS {0} (
@@ -228,7 +238,7 @@ CREATE TABLE IF NOT EXISTS {0} (
|
|
|
|
|
if (result == null) throw UmbrellaException.notFound("No task found for id {0}",taskId); |
|
|
|
|
return result; |
|
|
|
|
} catch (SQLException e) { |
|
|
|
|
throw new UmbrellaException(HTTP_SERVER_ERROR,"Failed to load task from database"); |
|
|
|
|
throw new UmbrellaException("Failed to load task from database"); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@ -261,7 +271,7 @@ CREATE TABLE IF NOT EXISTS {0} (
@@ -261,7 +271,7 @@ CREATE TABLE IF NOT EXISTS {0} (
|
|
|
|
|
} |
|
|
|
|
return task; |
|
|
|
|
} catch (SQLException e){ |
|
|
|
|
throw new UmbrellaException(HTTP_SERVER_ERROR,"Failed to save task {0}",task.name()); |
|
|
|
|
throw new UmbrellaException("Failed to save task {0}",task.name()); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@ -270,7 +280,7 @@ CREATE TABLE IF NOT EXISTS {0} (
@@ -270,7 +280,7 @@ CREATE TABLE IF NOT EXISTS {0} (
|
|
|
|
|
try { |
|
|
|
|
replaceInto(TABLE_TASKS_USERS,TASK_ID,USER_ID,PERMISSIONS).values(taskId,userId,permission.code()).execute(db).close(); |
|
|
|
|
} catch (SQLException e) { |
|
|
|
|
throw new UmbrellaException(HTTP_SERVER_ERROR,"Failed to store permissions"); |
|
|
|
|
throw new UmbrellaException("Failed to store permissions"); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|