临时提交同步数据

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/stone/StoneServerImpl.java

@@ -21,6 +21,7 @@ import com.liquidnet.service.stone.mapper.StoneScoreUserMapper;
 import com.liquidnet.service.stone.vo.StoneUserVo;
 import com.liquidnet.service.sweet.constant.SweetConstant;
 import com.liquidnet.service.sweet.vo.SweetAppletUsersVo;
+import com.mysql.cj.jdbc.result.ResultSetImpl;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -32,6 +33,9 @@ import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
 import java.time.LocalDateTime;
 import java.util.Arrays;
 import java.util.HashMap;
@@ -61,14 +65,27 @@ public class StoneServerImpl {
     @Autowired
     FeignStoneIntegralClient stoneIntegralClient;
 
-    private static final String SQL_URL = "jdbc:mysql://39.106.122.201:3308/test_ln_scene";
-    private static final String SQL_USER = "testmall";
-    private static final String SQL_PWD = "zhengzai!mYT";
-    private static final String ADAM_URL = "http://adam.zhengzai.tv";
+    private static final String SQL_URL = "jdbc:mysql://zhengzai.mysql.polardb.rds.aliyuncs.com:3306/ln_scene";
+    private static final String SQL_USER = "java";
+    private static final String SQL_PWD = "pOOs9Y3wj#2^";
 
     public boolean initScore(int page, int size) {
         try {
-
+            String sql = "select merchant_id, mm.mobile\n" +
+                    "from kylin_performances kp\n" +
+                    "         inner join kylin_performance_relations kpr on kpr.performance_id = kp.performances_id\n" +
+                    "         left join mall.merchants mm on mm.id = kpr.merchant_id\n" +
+                    "group by mm.mobile";
+            Connection connection = DriverManager.getConnection(SQL_URL, SQL_USER, SQL_PWD);
+            //查询数据
+            PreparedStatement preparedStatement = connection.prepareStatement(sql);
+            ResultSetImpl row = (ResultSetImpl) preparedStatement.executeQuery();
+            row.close();
+            preparedStatement.close();
+            //数据迁移
+            while (row.next()) {
+                
+            }
         } catch (Exception e) {
             log.info("异常 : {} ", e);
             e.printStackTrace();