wudianlong il y a 3 ans
Parent
commit
8f2b6d2560

+ 40 - 18
dw-db/src/main/java/com/saga/hbase/phoenix/app/PhoenixDDL.java

@@ -1,36 +1,58 @@
 package com.saga.hbase.phoenix.app;
 
-import com.saga.hbase.phoenix.bean.UsPopulation;
 import com.saga.hbase.phoenix.constant.PhoenixConstant;
 
-import java.lang.reflect.Field;
-import java.sql.*;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Properties;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
+import java.sql.Statement;
 
 public class PhoenixDDL {
 
 
+    private static Connection connection = null;
+    private static Statement statement = null;
+
+    static {
+        System.out.println("init phoenix config ... ");
+        try {
+            Class.forName(PhoenixConstant.PHOENIX_DRIVER);
+            connection = DriverManager.getConnection(PhoenixConstant.PHOENIX_SERVER);
+            statement = connection.createStatement();
+
+        } catch (ClassNotFoundException e) {
+            e.printStackTrace();
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+
+    }
 
     public static void main(String[] args) throws ClassNotFoundException, SQLException {
 
-        Class.forName(PhoenixConstant.PHOENIX_DRIVER);
-        Connection connection = DriverManager.getConnection(PhoenixConstant.PHOENIX_SERVER);
+    }
 
-        Statement statement = connection.createStatement();
-        ResultSet resultSet = statement.executeQuery("select * from SYSTEM.US_POPULATION");
+    public Integer createTable(String tableName) throws SQLException {
+        String sql="create table saga_log.test_phoenix_api(mykey integer not null primary key ,mycolumn varchar )";
+        int update = statement.executeUpdate(sql);
+        connection.commit();
+        return update;
+    }
 
-        int columnCount = resultSet.getMetaData().getColumnCount();
-        while (resultSet.next()){
-            for (int i = 1; i <= columnCount; i++) {
-                String state = resultSet.getString(i);
-                System.out.print(state + " ");
-            }
+    public Boolean deleteTable(String tableName){
 
-            System.out.println();
-        }
+        return true;
+    }
 
+    public static void closeConnection(){
+        try {
+            if (statement != null)
+                statement.close();
+            if (connection != null)
+                connection.close();
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
     }
 
 

+ 51 - 10
dw-db/src/main/java/com/saga/hbase/phoenix/app/PhoenixDML.java

@@ -1,36 +1,65 @@
 package com.saga.hbase.phoenix.app;
 
-import com.saga.hbase.phoenix.bean.UsPopulation;
 import com.saga.hbase.phoenix.constant.PhoenixConstant;
 
-import java.lang.reflect.Field;
 import java.sql.*;
-import java.util.List;
 
 
 public class PhoenixDML {
 
+    private static Connection connection = null;
+    private static Statement statement = null;
+
+    static {
+        System.out.println("init phoenix config ... ");
+        try {
+            Class.forName(PhoenixConstant.PHOENIX_DRIVER);
+            connection = DriverManager.getConnection(PhoenixConstant.PHOENIX_SERVER);
+            statement = connection.createStatement();
+
+        } catch (ClassNotFoundException e) {
+            e.printStackTrace();
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+
+    }
+
+    public static void main(String[] args) throws ClassNotFoundException, SQLException {
+
+        select("", "");
+        closeConnection();
+    }
+
+
     //TODO 查询
-    public static <T> List<T> select(String schema, String tableName, T t) throws ClassNotFoundException, SQLException {
+    public static void select(String schema, String tableName) throws ClassNotFoundException, SQLException {
         Class.forName(PhoenixConstant.PHOENIX_DRIVER);
         Connection connection = DriverManager.getConnection(PhoenixConstant.PHOENIX_SERVER);
 
         Statement statement = connection.createStatement();
         ResultSet resultSet = statement.executeQuery("select * from SYSTEM.US_POPULATION");
-        Field[] fields = t.getClass().getDeclaredFields();
 
+        int columnCount = resultSet.getMetaData().getColumnCount();
         while (resultSet.next()){
-            UsPopulation usPopulation = new UsPopulation();
-
-            for (Field field : fields) {
-                String state = resultSet.getString(field.getName());
+            for (int i = 1; i <= columnCount; i++) {
+                String state = resultSet.getString(i);
+                System.out.print(state + " ");
             }
+
+            System.out.println();
         }
-        return null;
     }
 
     //TODO 更新
     public Integer update(){
+        String sql1="upsert into test_phoenix_api values(1,'test1')";
+        String sql2="upsert into test_phoenix_api values(2,'test2')";
+        String sql3="upsert into test_phoenix_api values(3,'test3')";
+//        stat.executeUpdate(sql1);
+//        stat.executeUpdate(sql2);
+//        stat.executeUpdate(sql3);
+//        conn.commit();
         return 0;
     }
 
@@ -43,4 +72,16 @@ public class PhoenixDML {
     public Integer delete(){
         return 0;
     }
+
+
+    public static void closeConnection(){
+        try {
+            if (statement != null)
+                statement.close();
+            if (connection != null)
+                connection.close();
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+    }
 }

+ 13 - 0
dw-db/src/main/java/com/saga/hbase/phoenix/app/Test.java

@@ -0,0 +1,13 @@
+package com.saga.hbase.phoenix.app;
+
+import org.junit.After;
+import org.junit.Before;
+
+public class Test {
+
+
+    public static void main(String[] args) {
+
+    }
+
+}

+ 12 - 0
dw-db/src/main/java/com/saga/hbase/phoenix/bean/UsPopulation.java

@@ -0,0 +1,12 @@
+package com.saga.hbase.phoenix.bean;
+
+import lombok.Data;
+
+@Data
+public class UsPopulation {
+
+    private String state;
+    private String city;
+    private String population;
+
+}

+ 10 - 0
dw-flink/src/main/java/com/saga/flink/cdc/app/FlinkPhoenixDML.java

@@ -0,0 +1,10 @@
+package com.saga.flink.cdc.app;
+
+public class FlinkPhoenixDML {
+
+    public static void main(String[] args) {
+
+
+
+    }
+}

+ 13 - 0
dw-spring-db/src/main/java/com/saga/phoenix/DwSpringDbApplication.java

@@ -0,0 +1,13 @@
+package com.saga.phoenix;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class DwSpringDbApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(DwSpringDbApplication.class, args);
+    }
+
+}

+ 11 - 0
dw-spring-db/src/main/resources/application.yaml

@@ -0,0 +1,11 @@
+spring:
+  datasource:
+    type: com.alibaba.druid.pool.DruidDataSource
+    driver-class-name: org.apache.phoenix.jdbc.PhoenixDriver
+    url: jdbc:phoenix:192.168.19.148:2181
+    username: root
+    password: root
+
+mybatis:
+  mapper-locations: classpath:com/jun/mapper/*.xml
+  type-aliases-package: com.junjia.entity