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.actionsbatch.task;
35
36 import fr.paris.lutece.plugins.workflowcore.business.config.ITaskConfigDAO;
37 import fr.paris.lutece.util.sql.DAOUtil;
38
39 public class ActionsBatchTaskConfigDAO implements ITaskConfigDAO<ActionsBatchTaskConfig>
40 {
41
42
43 private static final String SQL_QUERY_SELECT = "SELECT id_task, id_workflow, id_state, id_action, resource_type FROM workflow_task_actions_batch_cf WHERE id_task = ?";
44 private static final String SQL_QUERY_INSERT = "INSERT INTO workflow_task_actions_batch_cf ( id_task, id_workflow, id_state, id_action, resource_type ) VALUES ( ?, ?, ?, ?, ? ) ";
45 private static final String SQL_QUERY_DELETE = "DELETE FROM workflow_task_actions_batch_cf WHERE id_task = ? ";
46 private static final String SQL_QUERY_UPDATE = "UPDATE workflow_task_actions_batch_cf SET id_workflow = ?, id_state = ?, id_action = ?, resource_type = ? WHERE id_task = ?";
47
48 @Override
49 public void insert( ActionsBatchTaskConfig config )
50 {
51 try ( DAOUtil daoUtil = new DAOUtil( SQL_QUERY_INSERT ) )
52 {
53 daoUtil.setInt( 1, config.getIdTask( ) );
54 daoUtil.setInt( 2, config.getIdWorkflow( ) );
55 daoUtil.setInt( 3, config.getIdState( ) );
56 daoUtil.setInt( 4, config.getIdAction( ) );
57 daoUtil.setString( 5, config.getResourceType( ) );
58 daoUtil.executeUpdate( );
59 }
60 }
61
62 @Override
63 public void store( ActionsBatchTaskConfig config )
64 {
65 try ( DAOUtil daoUtil = new DAOUtil( SQL_QUERY_UPDATE ) )
66 {
67 daoUtil.setInt( 1, config.getIdWorkflow( ) );
68 daoUtil.setInt( 2, config.getIdState( ) );
69 daoUtil.setInt( 3, config.getIdAction( ) );
70 daoUtil.setInt( 4, config.getIdTask( ) );
71 daoUtil.setString( 5, config.getResourceType( ) );
72 daoUtil.executeUpdate( );
73 }
74 }
75
76 @Override
77 public ActionsBatchTaskConfig load( int nIdTask )
78 {
79
80 ActionsBatchTaskConfig batchActionsTaskConfig = null;
81
82 try ( DAOUtil daoUtil = new DAOUtil( SQL_QUERY_SELECT ) )
83 {
84 daoUtil.setInt( 1, nIdTask );
85 daoUtil.executeQuery( );
86 if ( daoUtil.next( ) )
87 {
88 batchActionsTaskConfig = new ActionsBatchTaskConfig( );
89 int i = 1;
90 batchActionsTaskConfig.setIdTask( daoUtil.getInt( i++ ) );
91 batchActionsTaskConfig.setIdWorkflow( daoUtil.getInt( i++ ) );
92 batchActionsTaskConfig.setIdState( daoUtil.getInt( i++ ) );
93 batchActionsTaskConfig.setIdAction( daoUtil.getInt( i++ ) );
94 batchActionsTaskConfig.setResourceType( daoUtil.getString( i ) );
95 }
96 }
97
98 return batchActionsTaskConfig;
99 }
100
101 @Override
102 public void delete( int nIdTask )
103 {
104 try ( DAOUtil daoUtil = new DAOUtil( SQL_QUERY_DELETE ) )
105 {
106 daoUtil.setInt( 1, nIdTask );
107 daoUtil.executeUpdate( );
108 }
109 }
110
111 }