Skip to content

C
ctr-estimate
Commit 5e21efc3 authored by 赵建伟's avatar 赵建伟
Browse files
Options

update codes

parent 0e4fc883
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 2 deletions
src/main/java/com/gmei/data/ctr/sink/CtrEstimatePfrMysqlSink.java
View file @ 5e21efc3
...@@ -80,7 +80,7 @@ public class CtrEstimatePfrMysqlSink extends RichSinkFunction<DeviceCurrentEstim ...@@ -80,7 +80,7 @@ public class CtrEstimatePfrMysqlSink extends RichSinkFunction<DeviceCurrentEstim
*/ */
private void insert(DeviceCurrentEstimatePfrTmp deviceCurrentEstimatePfrTmp) { private void insert(DeviceCurrentEstimatePfrTmp deviceCurrentEstimatePfrTmp) {
Statement statement = null; Statement statement = null;
java.util.Date date = new Date(); Date date = new Date();
try{ try{
statement = connection.createStatement(); statement = connection.createStatement();
statement.executeUpdate( statement.executeUpdate(
...@@ -135,8 +135,9 @@ public class CtrEstimatePfrMysqlSink extends RichSinkFunction<DeviceCurrentEstim ...@@ -135,8 +135,9 @@ public class CtrEstimatePfrMysqlSink extends RichSinkFunction<DeviceCurrentEstim
*/ */
private void del(DeviceCurrentEstimatePfrTmp deviceCurrentEstimatePfrTmp) { private void del(DeviceCurrentEstimatePfrTmp deviceCurrentEstimatePfrTmp) {
Statement statement = null; Statement statement = null;
java.util.Date date = new Date(); Date date = new Date();
try{ try{
statement = connection.createStatement();
statement.executeUpdate( statement.executeUpdate(
String.format( String.format(
"delete from device_recently_estimate_view_pfr where " + "delete from device_recently_estimate_view_pfr where " +
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment