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 package fr.paris.lutece.plugins.workflow.modules.comment.business;
35
36 import fr.paris.lutece.portal.service.plugin.Plugin;
37 import fr.paris.lutece.util.sql.DAOUtil;
38
39
40
41
42
43
44 public class CommentValueDAO implements ICommentValueDAO
45 {
46 private static final String SQL_QUERY_FIND_BY_PRIMARY_KEY = "SELECT id_history,id_task,comment_value "
47 + "FROM workflow_task_comment_value WHERE id_history=? AND id_task=?";
48 private static final String SQL_QUERY_INSERT = "INSERT INTO workflow_task_comment_value " + "(id_history,id_task,comment_value )VALUES(?,?,?)";
49 private static final String SQL_QUERY_DELETE_BY_HISTORY = "DELETE FROM workflow_task_comment_value WHERE id_history=? AND id_task=?";
50 private static final String SQL_QUERY_DELETE_BY_TASK = "DELETE FROM workflow_task_comment_value WHERE id_task=?";
51
52
53
54
55 @Override
56 public synchronized void insert( CommentValue commentValue, Plugin plugin )
57 {
58 try ( DAOUtil daoUtil = new DAOUtil( SQL_QUERY_INSERT, plugin ) )
59 {
60 int nPos = 0;
61
62 daoUtil.setInt( ++nPos, commentValue.getIdResourceHistory( ) );
63 daoUtil.setInt( ++nPos, commentValue.getIdTask( ) );
64 daoUtil.setString( ++nPos, commentValue.getValue( ) );
65
66 daoUtil.executeUpdate( );
67 }
68 }
69
70
71
72
73 @Override
74 public CommentValue load( int nIdHistory, int nIdTask, Plugin plugin )
75 {
76 CommentValue commentValue = null;
77 try ( DAOUtil daoUtil = new DAOUtil( SQL_QUERY_FIND_BY_PRIMARY_KEY, plugin ) )
78 {
79 int nPos = 0;
80 daoUtil.setInt( ++nPos, nIdHistory );
81 daoUtil.setInt( ++nPos, nIdTask );
82 daoUtil.executeQuery( );
83
84 if ( daoUtil.next( ) )
85 {
86 nPos = 0;
87 commentValue = new CommentValue( );
88 commentValue.setIdResourceHistory( daoUtil.getInt( ++nPos ) );
89 commentValue.setIdTask( daoUtil.getInt( ++nPos ) );
90 commentValue.setValue( daoUtil.getString( ++nPos ) );
91 }
92 }
93 return commentValue;
94 }
95
96
97
98
99 @Override
100 public void deleteByHistory( int nIdHistory, int nIdTask, Plugin plugin )
101 {
102 try ( DAOUtil daoUtil = new DAOUtil( SQL_QUERY_DELETE_BY_HISTORY, plugin ) )
103 {
104 int nPos = 0;
105 daoUtil.setInt( ++nPos, nIdHistory );
106 daoUtil.setInt( ++nPos, nIdTask );
107
108 daoUtil.executeUpdate( );
109 }
110 }
111
112
113
114
115 @Override
116 public void deleteByTask( int nIdTask, Plugin plugin )
117 {
118 try ( DAOUtil daoUtil = new DAOUtil( SQL_QUERY_DELETE_BY_TASK, plugin ) )
119 {
120 int nPos = 0;
121 daoUtil.setInt( ++nPos, nIdTask );
122 daoUtil.executeUpdate( );
123 }
124 }
125 }