SqlServer BI 操做
一下鏈接為 SqlServer mdx 查詢的數據圖片 (主要是將數據集放在JavaBean，for (Position row : cellSet.getAxes().get(1)) 獲得行 for (Position row : cellSet.getAxes().get(0)) 獲得列 final Cell cell = cellSet.getCell(column, row); values.add(cell.getFormattedValue() == "" ? " " : cell.getFormattedValue()); // 這樣是按照ＡＰＩ來操做的 Thejava
)sql
package com.msi.mdxDemo;this
import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import org.joda.time.DateTime; import org.olap4j.Cell; import org.olap4j.CellSet; import org.olap4j.OlapConnection; import org.olap4j.OlapException; import org.olap4j.OlapStatement; import org.olap4j.Position;code
public class MyMdxDemo {orm
public OlapConnection getOlapConnection() {
OlapConnection olapConnection = null;
try {
Class.forName("org.olap4j.driver.xmla.XmlaOlap4jDriver");
Connection connection = DriverManager
.getConnection("jdbc:xmla:Server=http://172.17.0.37/OLAPService/msmdpump.dll;Catalog=B_SY_FPYWX");
olapConnection = connection.unwrap(OlapConnection.class);
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return olapConnection;
}
@SuppressWarnings("static-access")
public List<FpyBean> getFpyTb2(String lobNo, String day, int timeId) {
String day1 = "";
String day2 = "";
int timeId1 = timeId + 1;
List<FpyBean> list = new ArrayList<FpyBean>();
FpyBean bean = null;
try {
DateTime dt = new DateTime();
day2 = dt.parse(day).toString("yyyy-MM-dd");
day1 = dt.parse(day).plusDays(-1).toString("yyyy-MM-dd");// 往前推一天
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
String mdxSql = "";
if (lobNo.equals("SPD-MB")) {
lobNo = "DT-MB";
mdxSql = "SELECT({[DimTime].[日期].&["
+ day1
+ "T00:00:00]*{[DimTimeSection].[TimeSection].["
+ timeId1
+ "]:[DimTimeSection].[TimeSection].[12]}+[DimTime].[日期].&["
+ day2
+ "T00:00:00]*{[DimTimeSection].[TimeSection].[1]:[DimTimeSection].[TimeSection].["
+ timeId + "]}})";
mdxSql += " ON COLUMNS,non empty({[DimWorkOrder].[LobByProduct].&["
+ lobNo
+ "]}*{[DimLinepage].[線別].children}*{[DimStation].[站別].&[6],[DimStation].[站別].&[91]}*{[Measures].[生產數量],[Measures].[FAIL數量],[Measures].[生產良率]}) ON ROWS FROM [B_SY_FPYWX]";
} else if (lobNo.equals("SPD-BB") || lobNo.equals("EPS-BB")
|| lobNo.equals("IPS-BB")) {
if (lobNo.equals("SPD-BB")) {
lobNo = "DT-BB";
}
mdxSql = "SELECT({[DimTime].[日期].&["
+ day1
+ "T00:00:00]*{[DimTimeSection].[TimeSection].["
+ timeId1
+ "]:[DimTimeSection].[TimeSection].[12]}+[DimTime].[日期].&["
+ day2
+ "T00:00:00]*{[DimTimeSection].[TimeSection].[1]:[DimTimeSection].[TimeSection].["
+ timeId + "]}})";
mdxSql += " ON COLUMNS,non empty({[DimWorkOrder].[LobByProduct].&["
+ lobNo
+ "]}*{[DimLinepage].[線別].children}*{[DimStation].[站別].&[8],[DimStation].[站別].&[9],[DimStation].[站別].&[11]}*{[Measures].[生產數量],[Measures].[FAIL數量],[Measures].[生產良率]}) ON ROWS FROM [B_SY_FPYWX]";
} else if (lobNo.equals("VGA")) {
mdxSql = "SELECT({[DimTime].[日期].&["
+ day1
+ "T00:00:00]*{[DimTimeSection].[TimeSection].["
+ timeId1
+ "]:[DimTimeSection].[TimeSection].[12]}+[DimTime].[日期].&["
+ day2
+ "T00:00:00]*{[DimTimeSection].[TimeSection].[1]:[DimTimeSection].[TimeSection].["
+ timeId + "]}})";
mdxSql += " ON COLUMNS,non empty({[DimWorkOrder].[LobByProduct].&["
+ lobNo
+ "]}*{[DimLinepage].[線別].children}*{[DimStation].[站別].&[6],[DimStation].[站別].&[42],[DimStation].[站別].&[94],[DimStation].[站別].&[96],[DimStation].[站別].&[60]}*{[Measures].[生產數量],[Measures].[FAIL數量],[Measures].[生產良率]}) ON ROWS FROM [B_SY_FPYWX]";
} else if (lobNo.equals("VE ASSY")) {
lobNo = "VE";
mdxSql = "SELECT({[DimTime].[日期].&["
+ day1
+ "T00:00:00]*{[DimTimeSection].[TimeSection].["
+ timeId1
+ "]:[DimTimeSection].[TimeSection].[12]}+[DimTime].[日期].&["
+ day2
+ "T00:00:00]*{[DimTimeSection].[TimeSection].[1]:[DimTimeSection].[TimeSection].["
+ timeId + "]}})";
mdxSql += " ON COLUMNS,non empty({[DimWorkOrder].[LobByProduct].&["
+ lobNo
+ "]}*{[DimStation].[製程別].&[ASSY]}*{[DimLinepage].[線別].children}*{[DimStation].[站別].&[8],[DimStation].[站別].&[9],[DimStation].[站別].&[366]}*{[Measures].[生產數量],[Measures].[FAIL數量],[Measures].[生產良率]}) ON ROWS FROM [B_SY_FPYWX]";
} else if (lobNo.equals("VE PCBA")) {
lobNo = "VE";
mdxSql = "SELECT({[DimTime].[日期].&["
+ day1
+ "T00:00:00]*{[DimTimeSection].[TimeSection].["
+ timeId1
+ "]:[DimTimeSection].[TimeSection].[12]}+[DimTime].[日期].&["
+ day2
+ "T00:00:00]*{[DimTimeSection].[TimeSection].[1]:[DimTimeSection].[TimeSection].["
+ timeId + "]}})";
mdxSql += " ON COLUMNS,non empty({[DimWorkOrder].[LobByProduct].&["
+ lobNo
+ "]}*{[DimStation].[製程別].&[PCBA]}*{[DimLinepage].[線別].children}*{[DimStation].[站別].&[6]}*{[Measures].[生產數量],[Measures].[FAIL數量],[Measures].[生產良率]}) ON ROWS FROM [B_SY_FPYWX]";
} else if (lobNo.equals("ROBOT ASSY")) {
lobNo = "ROBOT";
mdxSql = "SELECT({[DimTime].[日期].&["
+ day1
+ "T00:00:00]*{[DimTimeSection].[TimeSection].["
+ timeId1
+ "]:[DimTimeSection].[TimeSection].[12]}+[DimTime].[日期].&["
+ day2
+ "T00:00:00]*{[DimTimeSection].[TimeSection].[1]:[DimTimeSection].[TimeSection].["
+ timeId + "]}})";
mdxSql += " ON COLUMNS,non empty({[DimWorkOrder].[LobByProduct].&["
+ lobNo
+ "]}*{[DimStation].[製程別].&[ASSY]}*{[DimLinepage].[線別].children}*{[DimStation].[站別].&[8],[DimStation].[站別].&[9],[DimStation].[站別].&[50],[DimStation].[站別].&[20]}*{[Measures].[生產數量],[Measures].[FAIL數量],[Measures].[生產良率]}) ON ROWS FROM [B_SY_FPYWX]";
} else if (lobNo.equals("ROBOT PCBA")) {
lobNo = "ROBOT";
mdxSql = "SELECT({[DimTime].[日期].&["
+ day1
+ "T00:00:00]*{[DimTimeSection].[TimeSection].["
+ timeId1
+ "]:[DimTimeSection].[TimeSection].[12]}+[DimTime].[日期].&["
+ day2
+ "T00:00:00]*{[DimTimeSection].[TimeSection].[1]:[DimTimeSection].[TimeSection].["
+ timeId + "]}})";
mdxSql += " ON COLUMNS,non empty({[DimWorkOrder].[LobByProduct].&["
+ lobNo
+ "]}*{[DimStation].[製程別].&[PCBA]}*{[DimLinepage].[線別].children}*{[DimStation].[站別].&[6]}*{[Measures].[生產數量],[Measures].[FAIL數量],[Measures].[生產良率]}) ON ROWS FROM [B_SY_FPYWX]";
} else {
if (lobNo.equals("SPD-SC")) {
lobNo = "Other Card";
}
mdxSql = "SELECT({[DimTime].[日期].&["
+ day1
+ "T00:00:00]*{[DimTimeSection].[TimeSection].["
+ timeId1
+ "]:[DimTimeSection].[TimeSection].[12]}+[DimTime].[日期].&["
+ day2
+ "T00:00:00]*{[DimTimeSection].[TimeSection].[1]:[DimTimeSection].[TimeSection].["
+ timeId + "]}})";
mdxSql += " ON COLUMNS,non empty({[DimWorkOrder].[LobByProduct].&["
+ lobNo
+ "]}*{[DimLinepage].[線別].children}*{[DimStation].[站別].&[6]}*{[Measures].[生產數量],[Measures].[FAIL數量],[Measures].[生產良率]}) ON ROWS FROM [B_SY_FPYWX]";
}
List<String> days = null; // new ArrayList<String>();
List<Integer> timeIds = null; // new ArrayList<Integer>();
List<String> values = null; // new ArrayList<String>();
OlapConnection olapConnection = null;
OlapStatement olapStatement = null;
CellSet cellSet = null;
try {
olapConnection = getOlapConnection();
olapStatement = olapConnection.createStatement();
cellSet = olapStatement.executeOlapQuery(mdxSql);
if (lobNo.equals("VE") || lobNo.equals("ROBOT")) {
for (Position row : cellSet.getAxes().get(1)) {
bean = new FpyBean();
bean.setLobNo(row.getMembers().get(0).getName() + " "
+ row.getMembers().get(1).getName());
bean.setLineNo(row.getMembers().get(2).getName());
bean.setStation(row.getMembers().get(3).getName());
bean.setItem(row.getMembers().get(4).getName());
days = new ArrayList<String>();
timeIds = new ArrayList<Integer>();
values = new ArrayList<String>();
for (Position column : cellSet.getAxes().get(0)) {
days.add(column.getMembers().get(0).getName());
timeIds.add(Integer.parseInt(column.getMembers().get(1)
.getName()));
final Cell cell = cellSet.getCell(column, row);
values.add(cell.getFormattedValue() == "" ? " " : cell
.getFormattedValue());
}
bean.setDay(days);
bean.setTimeId(timeIds);
bean.setValues(values);
list.add(bean);
}
} else {
// 當作二維數據進行操做
for (Position row : cellSet.getAxes().get(1)) { // 行操做
bean = new FpyBean();
bean.setLobNo(row.getMembers().get(0).getName());// 行的第一個單元格
bean.setLineNo(row.getMembers().get(1).getName());// 行的第二個單元格
bean.setStation(row.getMembers().get(2).getName());// 行的第三個單元格
bean.setItem(row.getMembers().get(3).getName());// 行的第四個單元格
// System.out.println(" LobNo()=" + bean.getLobNo() +
// " LineNo()=" + bean.getLineNo() + " Station()="+
// bean.getStation() + " Item()=" + bean.getItem());
days = new ArrayList<String>();
timeIds = new ArrayList<Integer>();
values = new ArrayList<String>();
for (Position column : cellSet.getAxes().get(0)) { // 以列開始
// System.out.println(column.getMembers().get(0).getName()+" "+column.getMembers().get(1).getName());
days.add(column.getMembers().get(0).getName());
timeIds.add(Integer.parseInt(column.getMembers().get(1)
.getName()));
final Cell cell = cellSet.getCell(column, row);
values.add(cell.getFormattedValue() == "" ? " " : cell
.getFormattedValue()); // 這樣是按照ＡＰＩ來操做的 The
// formatted value is
// never null. In
// particular, when the
// cell contains the MDX
// NULL value,
// getValue() will
// return the Java null
// value but this method
// will return the empty
// string "".
}
bean.setDay(days);
bean.setTimeId(timeIds);
bean.setValues(values);
list.add(bean);
}
}
} catch (OlapException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return list;
}
public static void main(String[] args) {
// TODO Auto-generated method stub
List<FpyBean> list = new MyMdxDemo().getFpyTb2("ROBOT ASSY",
"2014-01-21", 1);
for (int i = 0; i < list.size(); i++) {
System.out.println(list.get(i).getLobNo() + " "
+ list.get(i).getLineNo() + " " + list.get(i).getStation()
+ " " + list.get(i).getItem() + " "
+ list.get(i).getDay() + " " + list.get(i).getTimeId()
+ " " + list.get(i).getValues() + " ");
}
// 循環出Days List
if (list.get(0).getDay() != null || list.get(0).getDay().size() > 0) {
List<String> days = list.get(0).getDay();
for (int i = 0; i < days.size(); i++) {
System.err.print(days.get(i) + " ");
}
}
//循環出來mdx的結果的方法 ，主要是根據數據的類型,好比說FAIL數量 /生產數量/生產良率
//通常會有時間這個維度，將時間維度的長度做爲數據遍歷的長度
for (int i = 0; i < list.size(); i++) {
if (list.get(i).getItem().equals("FAIL數量")) {
for (int j = 0; j < list.get(i).getDay() .size() ; j++) {
System.out.print(list.get(i).getValues().get(j)+" ");
}
}
System.out.println(" ");
}
}
}xml
相關文章
- 1. Python操做sqlserver
- 2. SQLServer 索引操做
- 3. jdbc操做sqlserver數據庫
- 4. sqlserver操做geography方法
- 5. (轉)SQLServer分區表操做
- 6. dbutils操做sqlserver數據庫
- 7. SQLServer 理解copyonly備份操做
- 8. SQLServer學習之表的操做
- 9. Java數據庫操做（MySQL與SQLserver）
- 10. SQLServer存儲過程基本操做
- 更多相關文章...
- • SQL IN 操作符 - SQL 教程
- • SVN 檢出操作 - SVN 教程
- • RxJava操作符（十）自定義操作符
- • RxJava操作符（四）Combining
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. CVPR 2020 論文大盤點-光流篇
- 2. Photoshop教程_ps中怎麼載入圖案？PS圖案如何導入？
- 3. org.pentaho.di.core.exception.KettleDatabaseException:Error occurred while trying to connect to the
- 4. SonarQube Scanner execution execution Error --- Failed to upload report - 500: An error has occurred
- 5. idea 導入源碼包
- 6. python學習 day2——基礎學習
- 7. 3D將是頁遊市場新賽道？
- 8. osg--交互
- 9. OSG-交互
- 10. Idea、spring boot 圖片(pgn顯示、jpg不顯示)解決方案
歡迎關注本站公眾號,獲取更多信息
