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.notifycrmnoesb.business;
35
36 import fr.paris.lutece.plugins.workflow.modules.notifycrmnoesb.service.NotifyCRMNoEsbPlugin;
37 import fr.paris.lutece.plugins.workflowcore.business.config.ITaskConfigDAO;
38 import fr.paris.lutece.plugins.workflow.modules.notifycrmnoesb.business.TaskNotifyCRMConfig;
39 import fr.paris.lutece.util.sql.DAOUtil;
40
41
42
43
44
45
46
47 public class TaskNotifyCRMConfigDAO implements ITaskConfigDAO<TaskNotifyCRMConfig>
48 {
49 private static final String SQL_QUERY_FIND_BY_PRIMARY_KEY = " SELECT id_task, status_text, sender, object, message, is_demand_crm_creation FROM task_notify_crm_no_esb_cf WHERE id_task = ? ";
50 private static final String SQL_QUERY_INSERT = " INSERT INTO task_notify_crm_no_esb_cf( id_task, status_text, sender, object, message, is_demand_crm_creation ) VALUES ( ?,?,?,?,?,? ) ";
51 private static final String SQL_QUERY_UPDATE = "UPDATE task_notify_crm_no_esb_cf SET id_task = ?, status_text = ?,sender = ?, object = ?, message = ?, is_demand_crm_creation = ? WHERE id_task = ? ";
52 private static final String SQL_QUERY_DELETE = " DELETE FROM task_notify_crm_no_esb_cf WHERE id_task = ? ";
53
54
55
56 @Override
57 public synchronized void insert( TaskNotifyCRMConfig config )
58 {
59 DAOUtil daoUtil = new DAOUtil( SQL_QUERY_INSERT, NotifyCRMNoEsbPlugin.getPlugin( ) );
60
61 int nIndex = 1;
62
63 daoUtil.setInt( nIndex++, config.getIdTask( ) );
64 daoUtil.setString( nIndex++, config.getStatusText( ) );
65 daoUtil.setString( nIndex++, config.getSender( ) );
66 daoUtil.setString( nIndex++, config.getObject( ) );
67 daoUtil.setString( nIndex++, config.getMessage( ) );
68 daoUtil.setBoolean( nIndex++, config.getDemandCRMCreation());
69
70 daoUtil.executeUpdate( );
71 daoUtil.free( );
72 }
73
74
75
76
77 @Override
78 public void store( TaskNotifyCRMConfig config )
79 {
80 DAOUtil daoUtil = new DAOUtil( SQL_QUERY_UPDATE, NotifyCRMNoEsbPlugin.getPlugin( ) );
81
82 int nIndex = 1;
83
84 daoUtil.setInt( nIndex++, config.getIdTask( ) );
85 daoUtil.setString( nIndex++, config.getStatusText( ) );
86 daoUtil.setString( nIndex++, config.getSender( ) );
87 daoUtil.setString( nIndex++, config.getObject( ) );
88 daoUtil.setString( nIndex++, config.getMessage( ) );
89 daoUtil.setBoolean( nIndex++, config.getDemandCRMCreation( ) );
90
91 daoUtil.setInt( nIndex++, config.getIdTask( ) );
92 daoUtil.executeUpdate( );
93 daoUtil.free( );
94 }
95
96
97
98
99 @Override
100 public TaskNotifyCRMConfig load( int nIdTask )
101 {
102 TaskNotifyCRMConfig config = null;
103 DAOUtil daoUtil = new DAOUtil( SQL_QUERY_FIND_BY_PRIMARY_KEY, NotifyCRMNoEsbPlugin.getPlugin( ) );
104
105 daoUtil.setInt( 1, nIdTask );
106
107 daoUtil.executeQuery( );
108
109 int nIndex = 1;
110
111 if ( daoUtil.next( ) )
112 {
113 config = new TaskNotifyCRMConfig( );
114 config.setIdTask( daoUtil.getInt( nIndex++ ) );
115 config.setStatusText(daoUtil.getString( nIndex++ ) );
116 config.setSender(daoUtil.getString( nIndex++ ) );
117 config.setObject(daoUtil.getString( nIndex++ ) );
118 config.setMessage( daoUtil.getString( nIndex++ ) );
119 config.setDemandCRMCreation( daoUtil.getBoolean( nIndex++ ) );
120 }
121
122 daoUtil.free( );
123
124 return config;
125 }
126
127
128
129
130 @Override
131 public void delete( int nIdTask )
132 {
133 DAOUtil daoUtil = new DAOUtil( SQL_QUERY_DELETE, NotifyCRMNoEsbPlugin.getPlugin( ) );
134
135 daoUtil.setInt( 1, nIdTask );
136 daoUtil.executeUpdate( );
137 daoUtil.free( );
138 }
139 }