@@ -172,47 +172,49 @@ public static String getSQLUpsertStatement(Collection<ICONWeatherModel> entities
172
172
public static String getSQLUpsertStatement (
173
173
Collection <ICONWeatherModel > entities , String database_schema ) {
174
174
StringBuilder upsertStatementBuilder = new StringBuilder ();
175
- upsertStatementBuilder .append (
176
- "INSERT INTO "
177
- + database_schema
178
- + ".weather(\n "
179
- + "\t time, alb_rad, asob_s, aswdifd_s, aswdifu_s, aswdir_s, sobs_rad, p_20m, p_65m, p_131m, t_131m, t_2m, t_g, u_10m, u_131m, u_20m, u_216m, u_65m, v_10m, v_131m, v_20m, v_216m, v_65m, w_131m, w_20m, w_216m, w_65m, z0, coordinate_id)\n "
180
- + "\t VALUES " );
175
+ upsertStatementBuilder
176
+ .append ("INSERT INTO " )
177
+ .append (database_schema )
178
+ .append (".weather(\n " )
179
+ .append (
180
+ "\t time, alb_rad, asob_s, aswdifd_s, aswdifu_s, aswdir_s, sobs_rad, p_20m, p_65m, p_131m, t_131m, t_2m, t_g, u_10m, u_131m, u_20m, u_216m, u_65m, v_10m, v_131m, v_20m, v_216m, v_65m, w_131m, w_20m, w_216m, w_65m, z0, coordinate_id)\n " )
181
+ .append ("\t VALUES " );
181
182
entities .forEach (
182
- entity -> upsertStatementBuilder .append (entity .getSQLInsertValuesString () + ", " ));
183
+ entity -> upsertStatementBuilder .append (entity .getSQLInsertValuesString ()). append ( ", " ));
183
184
int lastComma = upsertStatementBuilder .lastIndexOf ("," );
184
185
upsertStatementBuilder .deleteCharAt (lastComma );
185
- upsertStatementBuilder .append ("ON CONFLICT (coordinate_id, time) DO UPDATE \n " + " SET " );
186
- upsertStatementBuilder .append (
187
- "time=excluded.time,\n "
188
- + " alb_rad=excluded.alb_rad,\n "
189
- + " asob_s=excluded.asob_s,\n "
190
- + " aswdifd_s=excluded.aswdifd_s,\n "
191
- + " aswdifu_s=excluded.aswdifu_s,\n "
192
- + " aswdir_s=excluded.aswdir_s,\n "
193
- + " sobs_rad=excluded.sobs_rad,\n "
194
- + " p_20m=excluded.p_20m,\n "
195
- + " p_65m=excluded.p_65m,\n "
196
- + " p_131m=excluded.p_131m,\n "
197
- + " t_131m=excluded.t_131m,\n "
198
- + " t_2m=excluded.t_2m,\n "
199
- + " t_g=excluded.t_g,\n "
200
- + " u_10m=excluded.u_10m,\n "
201
- + " u_131m=excluded.u_131m,\n "
202
- + " u_20m=excluded.u_20m,\n "
203
- + " u_216m=excluded.u_216m,\n "
204
- + " u_65m=excluded.u_65m,\n "
205
- + " v_10m=excluded.v_10m,\n "
206
- + " v_131m=excluded.v_131m,\n "
207
- + " v_20m=excluded.v_20m,\n "
208
- + " v_216m=excluded.v_216m,\n "
209
- + " v_65m=excluded.v_65m,\n "
210
- + " w_131m=excluded.w_131m,\n "
211
- + " w_20m=excluded.w_20m,\n "
212
- + " w_216m=excluded.w_216m,\n "
213
- + " w_65m=excluded.w_65m,\n "
214
- + " z0=excluded.z0,\n "
215
- + " coordinate_id=excluded.coordinate_id;" );
186
+ upsertStatementBuilder
187
+ .append ("ON CONFLICT (coordinate_id, time) DO UPDATE \n " + " SET " )
188
+ .append (
189
+ "time=excluded.time,\n "
190
+ + " alb_rad=excluded.alb_rad,\n "
191
+ + " asob_s=excluded.asob_s,\n "
192
+ + " aswdifd_s=excluded.aswdifd_s,\n "
193
+ + " aswdifu_s=excluded.aswdifu_s,\n "
194
+ + " aswdir_s=excluded.aswdir_s,\n "
195
+ + " sobs_rad=excluded.sobs_rad,\n "
196
+ + " p_20m=excluded.p_20m,\n "
197
+ + " p_65m=excluded.p_65m,\n "
198
+ + " p_131m=excluded.p_131m,\n "
199
+ + " t_131m=excluded.t_131m,\n "
200
+ + " t_2m=excluded.t_2m,\n "
201
+ + " t_g=excluded.t_g,\n "
202
+ + " u_10m=excluded.u_10m,\n "
203
+ + " u_131m=excluded.u_131m,\n "
204
+ + " u_20m=excluded.u_20m,\n "
205
+ + " u_216m=excluded.u_216m,\n "
206
+ + " u_65m=excluded.u_65m,\n "
207
+ + " v_10m=excluded.v_10m,\n "
208
+ + " v_131m=excluded.v_131m,\n "
209
+ + " v_20m=excluded.v_20m,\n "
210
+ + " v_216m=excluded.v_216m,\n "
211
+ + " v_65m=excluded.v_65m,\n "
212
+ + " w_131m=excluded.w_131m,\n "
213
+ + " w_20m=excluded.w_20m,\n "
214
+ + " w_216m=excluded.w_216m,\n "
215
+ + " w_65m=excluded.w_65m,\n "
216
+ + " z0=excluded.z0,\n "
217
+ + " coordinate_id=excluded.coordinate_id;" );
216
218
return upsertStatementBuilder .toString ();
217
219
}
218
220
0 commit comments