hivejdbc测试

louzin_hdfsapi/src/main/java/com/louzin/hiveapi/util/jdbcHiveConnect.java

@@ -7,6 +7,7 @@ import org.junit.Test;
 import java.sql.*;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
 
 public class jdbcHiveConnect {
     public jdbcHiveConnect(){}
@@ -62,6 +63,32 @@ public class jdbcHiveConnect {
         }
         lists.forEach(item-> System.out.println(item.toString()));
     }
+    @Test
+    public List selectData_day_pv() throws SQLException, ClassNotFoundException {
+        Class.forName(driverName);
+        conn = DriverManager.getConnection(url,user,password);
+        stmt = conn.createStatement();
+        String sql="select remote_addr,COUNT(remote_addr)as pv" +
+                " from ods_weblog_detail" +
+                " group by remote_addr order by pv desc limit 10";
+        rs=stmt.executeQuery(sql);
+        List lists=new ArrayList<>();
+        while (rs.next()){
+            Map<String,String> copymap=Map.of("value",rs.getString(2),"name",rs.getString(1));
+            lists.add(copymap);
+        }
+        if ( rs != null) {
+            rs.close();
+        }
+        if (stmt != null) {
+            stmt.close();
+        }
+        if (conn != null) {
+            conn.close();
+        }
+//        return lists;
+        return lists;
+    }
     @After
     public void destory() throws Exception {
         if ( rs != null) {

webServer/src/main/java/com/louzin/webserver/WebServerApplication.java

@@ -3,15 +3,16 @@ package com.louzin.webserver;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.ResponseBody;
 import com.louzin.hiveapi.util.jdbcHiveConnect;
 
-import java.sql.SQLException;
 import java.util.List;
 
 @SpringBootApplication
 @Controller
+@CrossOrigin
 public class WebServerApplication {
 
     public static void main(String[] args) {
@@ -22,4 +23,9 @@ public class WebServerApplication {
 //    public List<String> saupl() throws SQLException, ClassNotFoundException {
 //        return new jdbcHiveConnect().showAllTable();
 //    }
+    @PostMapping("/getpv")
+    @ResponseBody
+    public List sauql() throws Exception{
+        return new jdbcHiveConnect().selectData_day_pv();
+    }
 }