Java的數據計算類庫RowSet提供了JoinRowSet和FilteredRowSet類，可以進行跨庫的關聯計算，但是有很多局限。首先，JoinRowSet只支持inner

join，不支持outter join。其次，db2、mysql和hsql經過測試是可以使用JoinRowSet的，但是oracle

11g和其他數據庫關聯的的時候雖然不報錯，但是結果集為空。而oracle11g的兩個數據庫用戶跨庫做join，使用JoinRowSet可以得到正確的結果。所以說不同數據庫廠家提供的Jdbc實現可能會影響上述方法的結果。第三，就是編程還是有點復雜。

集算器esProc能很好配合java完成跨庫連接。集算器支持各種數據庫，包括：oracle、db2、mysql、sqlserver、sybase、postgresql等，均可完成多數據混合的inner

join和outter

join等各種跨庫關聯運算。下面我們通過例子來看一下具體作法：要將db2中的sales表和mysql數據庫中的employee表通過sale.sellerid和employee.eid關聯，過濾出state=”California”的所有sales和employee數據。例子雖然是db2和mysql，其他數據庫的寫法也是類似的。

Sales表的結構和數據如下：

Employee表的結構和數據如下：

實現的思路是：用Java程序調用集算器腳本，連接多個數據庫實現關聯和過濾計算后將結果以ResultSet的方式返回給Java程序。

esProc代碼如下：

A1：連接預先配置好的db2數據源。

A2：連接預先配置好的mysql數據源。實際上對于oracle等其他數據庫也同樣支持。

A3、A4：分別從db2和mysql中讀取sales序表和employee序表。esProc的集成開發環境可以直觀的顯示出導入的數據，如上圖右邊部分。

A5：使用集算器的對象引用機制，將sales序表和employee序表通過sellerid=eid關聯。

A6：按照state="California"過濾序表。

A7：生成一個新的序表，得到需要的字段。

A8：返回給集算器程序的調用者。

在Java程序中使用esProc

JDBC調用這段程序獲得結果的代碼如下：(將上述esProc程序保存為test.dfx)：

//建立esProcjdbc連接

Class.forName("com.esproc.jdbc.InternalDriver");

con=

DriverManager.getConnection("jdbc:esproc:local://");

//調用esProc程序(存儲過程)，其中test是dfx的文件名

com.esproc.jdbc.InternalCStatement st;

st

=(com.esproc.jdbc.InternalCStatement)con.prepareCall("call

test()");

//執行esProc存儲過程

st.execute();

//獲取結果集

ResultSet set = st.getResultSet();

總結

以上是生活随笔為你收集整理的java跨库join方案_集算器协助java处理多样性数据源之跨库关联的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。