powerbi java用户名密码登录

痛定思痛。 2022-12-08 05:34 188阅读 0赞

#### 1 实现代码 ####

/** * 通过密码获取token * * @return token */
        private String getPasswordToken(){ 
    
            String token = "";
            String url = "https://login.partner.microsoftonline.cn/common/oauth2/token";
    
            Map<String, String> header = new HashMap<>(16);
            header.put("Content-Type", "application/x-www-form-urlencoded");
            header.put("Accept", "*/*");
    
            Map<String, String> body = new HashMap<>(16);
            body.put("resource", "https://analysis.chinacloudapi.cn/powerbi/api");
            body.put("client_id", CLIENT_ID);
            body.put("client_secret", CLIENT_SECRET);
            body.put("grant_type", "password");
            body.put("username", USERNAME);
            body.put("password", PASSWORD);
    
            StringBuilder bodyStr = new StringBuilder();
            int i = 0;
            for (Map.Entry<String, String> entry : body.entrySet()) { 
                i++;
                bodyStr.append(entry.getKey()).append("=").append(entry.getValue());
                if (i < body.size()) { 
                    bodyStr.append("&");
                }
            }
    
            String baseStr = httpUtil.doPost(url, header, bodyStr.toString());
    
            JSONObject jsonObject = JSONObject.parseObject(baseStr);
            token = jsonObject.getString("access_token");
    
            return token;
        }

#### 2 其他方法 ####

/** * 发送post请求 * * @param url 请求路径 * @param header 请求头 * @param body 请求体 * @return String */
        public String doPost(String url, Map<String, String> header, String body) { 
    
            String result = "";
            BufferedReader in = null;
            PrintWriter out = null;
            try { 
                // 设置 url
                URL realUrl = new URL(url);
                HttpURLConnection connection = (HttpURLConnection) realUrl.openConnection();
                connection.setRequestMethod("POST");
                // 设置 header
                for (Map.Entry<String, String> entry : header.entrySet()) { 
                    connection.setRequestProperty(entry.getKey(), entry.getValue());
                }
                // 设置请求 body
                connection.setDoOutput(true);
                connection.setDoInput(true);
    
                //设置连接超时和读取超时时间
                connection.setConnectTimeout(TWOTHOUSAND);
                connection.setReadTimeout(TWOTHOUSAND);
                try { 
                    out = new PrintWriter(connection.getOutputStream());
                    // 保存body
                    out.print(body);
                    // 发送body
                    out.flush();
                } catch (Exception e) { 
                    e.printStackTrace();
                }
                try { 
                    // 获取响应body
                    in = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
                    String line;
                    while ((line = in.readLine()) != null) { 
                        result += line;
                    }
                } catch (Exception e) { 
                    e.printStackTrace();
                }
            } catch (Exception e) { 
                e.printStackTrace();
                //return null;
            }
            return result;
        }