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.portal.business.datastore;
35
36 import fr.paris.lutece.util.sql.DAOUtil;
37
38 import java.util.ArrayList;
39 import java.util.List;
40
41
42
43
44 public final class DataEntityDAO implements IDataEntityDAO
45 {
46
47 private static final String SQL_QUERY_SELECT = "SELECT entity_key, entity_value FROM core_datastore WHERE entity_key = ?";
48 private static final String SQL_QUERY_INSERT = "INSERT INTO core_datastore ( entity_key, entity_value ) VALUES ( ?, ? ) ";
49 private static final String SQL_QUERY_DELETE = "DELETE FROM core_datastore WHERE entity_key = ? ";
50 private static final String SQL_QUERY_UPDATE = "UPDATE core_datastore SET entity_value = ? WHERE entity_key = ?";
51 private static final String SQL_QUERY_SELECTALL = "SELECT entity_key, entity_value FROM core_datastore";
52 private static final String SQL_QUERY_SELECTBYPREFIX = "SELECT entity_key, entity_value FROM core_datastore WHERE entity_key LIKE ?";
53
54
55
56
57
58
59
60 @Override
61 public void insert( DataEntity entity )
62 {
63 try ( DAOUtil/DAOUtil.html#DAOUtil">DAOUtil daoUtil = new DAOUtil( SQL_QUERY_INSERT ) )
64 {
65
66 daoUtil.setString( 1, entity.getKey( ) );
67 daoUtil.setString( 2, entity.getValue( ) );
68
69 daoUtil.executeUpdate( );
70 }
71 }
72
73
74
75
76
77
78
79
80 @Override
81 public DataEntity load( String strKey )
82 {
83 DataEntity entity = null;
84 try ( DAOUtil/DAOUtil.html#DAOUtil">DAOUtil daoUtil = new DAOUtil( SQL_QUERY_SELECT ) )
85 {
86 daoUtil.setString( 1, strKey );
87 daoUtil.executeQuery( );
88
89 if ( daoUtil.next( ) )
90 {
91 entity = new DataEntity( );
92
93 entity.setKey( daoUtil.getString( 1 ) );
94 entity.setValue( daoUtil.getString( 2 ) );
95 }
96
97 }
98
99 return entity;
100 }
101
102
103
104
105
106
107
108 @Override
109 public void delete( String strKey )
110 {
111 try ( DAOUtil/DAOUtil.html#DAOUtil">DAOUtil daoUtil = new DAOUtil( SQL_QUERY_DELETE ) )
112 {
113 daoUtil.setString( 1, strKey );
114 daoUtil.executeUpdate( );
115 }
116 }
117
118
119
120
121
122
123
124 @Override
125 public void store( DataEntity entity )
126 {
127 try ( DAOUtil/DAOUtil.html#DAOUtil">DAOUtil daoUtil = new DAOUtil( SQL_QUERY_UPDATE ) )
128 {
129
130 daoUtil.setString( 1, entity.getValue( ) );
131 daoUtil.setString( 2, entity.getKey( ) );
132
133 daoUtil.executeUpdate( );
134 }
135 }
136
137
138
139
140
141
142 @Override
143 public List<DataEntity> selectEntitiesList( )
144 {
145 List<DataEntity> entityList = new ArrayList<>( );
146 try ( DAOUtil/DAOUtil.html#DAOUtil">DAOUtil daoUtil = new DAOUtil( SQL_QUERY_SELECTALL ) )
147 {
148 daoUtil.executeQuery( );
149
150 while ( daoUtil.next( ) )
151 {
152 DataEntityiness/datastore/DataEntity.html#DataEntity">DataEntity entity = new DataEntity( );
153
154 entity.setKey( daoUtil.getString( 1 ) );
155 entity.setValue( daoUtil.getString( 2 ) );
156
157 entityList.add( entity );
158 }
159
160 }
161
162 return entityList;
163 }
164
165 @Override
166 public List<DataEntity> selectEntitiesByPrefix( String strPrefix )
167 {
168 List<DataEntity> entityList = new ArrayList<>( );
169 try ( DAOUtil/DAOUtil.html#DAOUtil">DAOUtil daoUtil = new DAOUtil( SQL_QUERY_SELECTBYPREFIX ) )
170 {
171 daoUtil.setString( 1, strPrefix + "%" );
172 daoUtil.executeQuery( );
173
174 while ( daoUtil.next( ) )
175 {
176 DataEntityiness/datastore/DataEntity.html#DataEntity">DataEntity entity = new DataEntity( );
177
178 entity.setKey( daoUtil.getString( 1 ) );
179 entity.setValue( daoUtil.getString( 2 ) );
180
181 entityList.add( entity );
182 }
183
184 }
185 return entityList;
186 }
187 }