diff --git a/louzin_hdfsapi/src/main/java/com/louzin/hiveapi/util/jdbcHiveConnect.java b/louzin_hdfsapi/src/main/java/com/louzin/hiveapi/util/jdbcHiveConnect.java index 05b2edc..f353054 100644 --- a/louzin_hdfsapi/src/main/java/com/louzin/hiveapi/util/jdbcHiveConnect.java +++ b/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 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) { diff --git a/webServer/src/main/java/com/louzin/webserver/WebServerApplication.java b/webServer/src/main/java/com/louzin/webserver/WebServerApplication.java index dfda0a7..69a0456 100644 --- a/webServer/src/main/java/com/louzin/webserver/WebServerApplication.java +++ b/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 saupl() throws SQLException, ClassNotFoundException { // return new jdbcHiveConnect().showAllTable(); // } + @PostMapping("/getpv") + @ResponseBody + public List sauql() throws Exception{ + return new jdbcHiveConnect().selectData_day_pv(); + } }