2007年6月27日
由于項目需要從EXCEL文件中導入數據,所以這幾天上網收集了一下這方面的資料!
于是找到了POI這個玩意,本來想用JXL的,但了解到它對處理數據量大的時候,效率不行!.于是選擇了POI!
要求:JDK 1.4+POI開發包
可以到
http://www.apache.org/dyn/closer.cgi/jakarta/poi/ 下載
Jakarta POIJakarta POI可以讓你使用Java來讀寫MS Excel ,Word文件
相關文檔官方網站:
http://jakarta.apache.org/poi/ http://www.matrix.org.cn/down_view.asp?id=14 www.matrix.org.cn上的東西一向很不錯!!
創建Excel 文檔 示例1將演示如何利用Jakarta POI API 創建Excel 文檔。
示例1程序如下：
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.hssf.usermodel.HSSFSheet;
import org.apache.poi.hssf.usermodel.HSSFRow;
import org.apache.poi.hssf.usermodel.HSSFCell;
import java.io.FileOutputStream;
public class CreateXL {
/** Excel 文件要存放的位置，假定在D盤下*/
public static String outputFile="D:\\test.xls";
public static void main(String argv[]){
try{
// 創建新的Excel 工作簿
HSSFWorkbook workbook = new HSSFWorkbook();
// 在Excel工作簿中建一工作表，其名為缺省值
// 如要新建一名為"效益指標"的工作表，其語句為：
// HSSFSheet sheet = workbook.createSheet("效益指標");
HSSFSheet sheet = workbook.createSheet();
// 在索引0的位置創建行（最頂端的行）
HSSFRow row = sheet.createRow((short)0);
//在索引0的位置創建單元格（左上端）
HSSFCell cell = row.createCell((short) 0);
// 定義單元格為字符串類型
cell.setCellType(HSSFCell.CELL_TYPE_STRING);
// 在單元格中輸入一些內容
cell.setCellValue("增加值");
// 新建一輸出文件流
FileOutputStream fOut = new FileOutputStream(outputFile);
// 把相應的Excel 工作簿存盤
workbook.write(fOut);
fOut.flush();
// 操作結束，關閉文件
fOut.close();
System.out.println("文件生成...");
}catch(Exception e) {
System.out.println("已運行 xlCreate() : " + e );
}
}
}
讀取Excel文檔中的數據 示例2將演示如何讀取Excel文檔中的數據。假定在D盤JTest目錄下有一個文件名為test1.xls的Excel文件。
示例2程序如下：
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.hssf.usermodel.HSSFSheet;
import org.apache.poi.hssf.usermodel.HSSFRow;
import org.apache.poi.hssf.usermodel.HSSFCell;
import java.io.FileInputStream;
public class ReadXL {
/** Excel文件的存放位置。注意是正斜線*/
public static String fileToBeRead="D:\\test1.xls";
public static void main(String argv[]){
try{
// 創建對Excel工作簿文件的引用
HSSFWorkbook workbook = new HSSFWorkbook(new FileInputStream(fileToBeRead));
// 創建對工作表的引用。
// 本例是按名引用（讓我們假定那張表有著缺省名"Sheet1"）
HSSFSheet sheet = workbook.getSheet("Sheet1");
// 也可用getSheetAt(int index)按索引引用，
// 在Excel文檔中，第一張工作表的缺省索引是0，
// 其語句為：HSSFSheet sheet = workbook.getSheetAt(0);
// 讀取左上端單元
HSSFRow row = sheet.getRow(0);
HSSFCell cell = row.getCell((short)0);
// 輸出單元內容，cell.getStringCellValue()就是取所在單元的值
System.out.println("左上端單元是： " + cell.getStringCellValue());
}catch(Exception e) {
System.out.println("已運行xlRead() : " + e );
}
}
}
設置單元格格式
在這里，我們將只介紹一些和格式設置有關的語句，我們假定workbook就是對一個工作簿的引用。在Java中，第一步要做的就是創建和設置字體和單元格的格式，然后再應用這些格式：
1、創建字體，設置其為紅色、粗體：
HSSFFont font = workbook.createFont();
font.setColor(HSSFFont.COLOR_RED);
font.setBoldweight(HSSFFont.BOLDWEIGHT_BOLD);
2、創建格式
HSSFCellStyle cellStyle= workbook.createCellStyle();
cellStyle.setFont(font);
3、應用格式
HSSFCell cell = row.createCell((short) 0);
cell.setCellStyle(cellStyle);
cell.setCellType(HSSFCell.CELL_TYPE_STRING);
cell.setCellValue("標題 ");
處理WORD文檔import java.io.*;
import org.textmining.text.extraction.WordExtractor;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.hssf.usermodel.HSSFSheet;
import org.apache.poi.hssf.usermodel.HSSFRow;
import org.apache.poi.hssf.usermodel.HSSFCell;
public class TestPoi {
public TestPoi() {
}
public static void main(String args[]) throws Exception
{
FileInputStream in = new FileInputStream ("D:\\a.doc");
WordExtractor extractor = new WordExtractor();
String str = extractor.extractText(in);
//System.out.println("the result length is"+str.length());
System.out.println(str);
}
}
在審批流程中，加入處理前和處理后的數據處理，可以將審批流程外的業務處理或是流程額外程序出來分離出來。放在代碼前，代碼后處理。
public WfActivity assignComplete(WfTranstion wfTrans,String procId, String activityId,
String touserId,String memo,HttpServletRequest request)throws WfException {
WfActivity wfAct = null;
try {
CodeFormula.parseBeforeCode(wfTrans.getConnection(),procId,activityId,CodeFormula.apply_code,request);
CheckAgree.execute(wfTrans,procId, activityId, new WfUser(uname, pwd),流程自己處理的方法
touserId,memo);
CodeFormula.parseAfterCode(wfTrans.getConnection(),procId,activityId,CodeFormula.apply_code,request);
} catch (WfException e) {
wfAct = null;
throw e;
}
return wfAct;
}
package com.borland.samples.welcome;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.File;
public class ReadFile {
public ReadFile() {}
/**
* 刪除某個文件夾下的所有文件夾和文件
* @param delpath String
* @throws FileNotFoundException
* @throws IOException
* @return boolean
*/
public static boolean deletefile(String delpath) throws FileNotFoundException,
IOException {
try {
File file = new File(delpath);
if (!file.isDirectory()) {
System.out.println("1");
file.delete();
}
else if (file.isDirectory()) {
System.out.println("2");
String[] filelist = file.list();
for (int i = 0; i < filelist.length; i++) {
File delfile = new File(delpath + "\\" + filelist[i]);
if (!delfile.isDirectory()) {
System.out.println("path=" + delfile.getPath());
System.out.println("absolutepath=" + delfile.getAbsolutePath());
System.out.println("name=" + delfile.getName());
delfile.delete();
System.out.println("刪除文件成功");
}
else if (delfile.isDirectory()) {
deletefile(delpath + "\\" + filelist[i]);
}
}
file.delete();
}
}
catch (FileNotFoundException e) {
System.out.println("deletefile() Exception:" + e.getMessage());
}
return true;
}
/**
* 刪除某個文件夾下的所有文件夾和文件
* @param delpath String
* @throws FileNotFoundException
* @throws IOException
* @return boolean
*/
public static boolean readfile(String filepath) throws FileNotFoundException,
IOException {
try {
File file = new File(filepath);
if (!file.isDirectory()) {
System.out.println("文件");
System.out.println("path=" + file.getPath());
System.out.println("absolutepath=" + file.getAbsolutePath());
System.out.println("name=" + file.getName());
}
else if (file.isDirectory()) {
System.out.println("文件夾");
String[] filelist = file.list();
for (int i = 0; i < filelist.length; i++) {
File readfile = new File(filepath + "\\" + filelist[i]);
if (!readfile.isDirectory()) {
System.out.println("path=" + readfile.getPath());
System.out.println("absolutepath=" + readfile.getAbsolutePath());
System.out.println("name=" + readfile.getName());
}
else if (readfile.isDirectory()) {
readfile(filepath + "\\" + filelist[i]);
}
}
}
}
catch (FileNotFoundException e) {
System.out.println("readfile() Exception:" + e.getMessage());
}
return true;
}
public static void main(String[] args) {
try {
readfile("D:/file");
//deletefile("D:/file");
}
catch (FileNotFoundException ex) {
}
catch (IOException ex) {
}
System.out.println("ok");
}
}
很多人都對java在批量數據的處理方面是否是其合適的場所持有懷疑的念頭，由此延伸，那么就會認為orm可能也不是特別適合數據的批量處理。 其實，我想如果我們應用得當的話，完全可以消除orm批量處理性能問題這方面的顧慮。下面以hibernate為例來做為說明，假如我們真的不得不在java中使用hibernate來對數據進行批量處理的話。 向數據庫插入100 000條數據，用hibernate可能像這樣：
session session = sessionfactory.opensession();
transaction tx = session.begintransaction();
for ( int i=0; i<100000; i++ ) {
customer customer = new customer(.....);
session.save(customer); }
tx.commit();
session.close();
大概在運行到第50 000條的時候，就會出現內存溢出而失敗。這是hibernate把最近插入的customer都以session-level cache在內存做緩存，我們不要忘記hiberante并沒有限制first-level cache 的緩存大小：
# 持久對象實例被管理在事務結束時，此時hibernate與數據庫同步任何已經發生變 化的被管理的的對象。
# session實現了異步write-behind，它允許hibernate顯式地寫操作的批處理。 這里，我給出hibernate如何實現批量插入的方法：
首先，我們設置一個合理的jdbc批處理大小，hibernate.jdbc.batch_size 20。 然后在一定間隔對session進行flush()和clear()。
session session = sessionfactory.opensession();
transaction tx = session.begintransaction();
for ( int i=0; i<100000; i++ ) {
customer customer = new customer(.....);
session.save(customer);
if ( i % 20 == 0 ) {
//flush 插入數據和釋放內存:
session.flush(); session.clear(); }
}
tx.commit();
session.close();
那么，關于怎樣刪除和更新數據呢？那好，在hibernate2.1.6或者更后版本，scroll() 這個方法將是最好的途徑：
session session = sessionfactory.opensession();
transaction tx = session.begintransaction();
scrollableresults customers = session.getnamedquery("getcustomers")
.scroll(scrollmode.forward_only);
int count=0;
while ( customers.next() ) {
customer customer = (customer) customers.get(0);
customer.updatestuff(...);
if ( ++count % 20 == 0 ) {
//flush 更新數據和釋放內存:
session.flush(); session.clear(); } }
tx.commit(); session.close();
這種做法并不困難，也不算不優雅。請注意，如果customer啟用了second-level caching ，我們仍然會有一些內存管理的問題。原因就是對于用戶的每一次插入和更新，hibernate在事務處理結束后不得不通告second-level cache 。因此，我們在批處理情況下將要禁用用戶使用緩存。
當你在開發程序的時候, 調試(debugging)和日志(logging)都是非常重要的工作, 但是, 現在有太多的 logging api 問世, 因為他們都不錯, 很難做一個抉擇. 國外 java 論壇對于這些 logging 方式也是有一番討論.
而 common logging 就是一個在這幾個不同的 logging api 中建立小小的橋梁.目前在 java 中最有名的 log 方式, 首推是 log4j, 另是 jdk 1.4 logging api. 除此之外, 還有 avalon 中用的 logkit 等等 . 而 commons-logging 也有實現一些基本 的 logging 方式為 nooplog 及 simplelog. 對于他們的比較不在這次討論范圍,
有興趣者請自行參閱參考文件.
快速使用 logging 其實 logging 非常簡單去使用, 將 commons-logging.jar 放到 /web-inf/lib 之下.接著寫以下的代碼
loggingtest.java
package com.softleader.newspaper.java.opensource;
import org.apache.commons.logging.log;
import org.apache.commons.logging.logfactory;
public class loggingtest {
log log = logfactory.getlog(loggingtest.class);
public void hello() {
log.error("error");
log.debug("debug");
log.warn("warn");
log.info("info");
log.trace("trace");
system.out.println("okok");
}
}
在 / 放置一個 jsp 測試 test-commons-logging.jsp
<%@ page import="com.softleader.newspaper.java.opensource.loggingtest" %>
<% loggingtest test = new loggingtest(); test.hello();%>
你將會看到 tomcat console 會有下面輸出
log4j:warn no appenders could be found for logger (com.softleader.newspaper.java.opensource.loggingtest).
log4j:warn please initialize the log4j system properly.okok
是因為你還沒有配置 commons-logging.properties, 馬上會為你介紹 ~~~.
設定 commons-logging.properties 你可以設置你的 log factory 是要使用哪一個 我以 log4j 為例子 在 /web-inf/classes/commons-logging.properties 中寫入
org.apache.commons.logging.log=org.apache.commons.logging.impl.log4jcategorylog
如果你 server 是使用 jdk1.4 以上的版本
可以使用 org.apache.commons.logging.impl.jdk14logger
接著根據你的 logger 撰寫符合他的 properties 拿 log4j 為例子 你就要在
/web-inf/classes/ 下放置一個 log4j.properties
//日志輸出到文件
log4j.rootlogger=debug, a_default
log4j.appender.a_default=org.apache.log4j.rollingfileappender
log4j.appender.a_default.file=c://log/test.log
log4j.appender.a_default.maxfilesize=4000kb
log4j.appender.a_default.maxbackupindex=10
log4j.appender.a_default.layout=org.apache.log4j.patternlayout
log4j.appender.a_default.layout.conversionpattern=%d{iso8601} - %p - %m%n
# 比較完整的輸出
# log4j.appender.a_default.layout.conversionpattern=%d %-5p [%t] %-17c{2} (%13f:%l) %3x - %m%n
//日志輸出到控制臺
log4j.rootlogger=info, a1
log4j.appender.a1=org.apache.log4j.consoleappender
log4j.appender.a1.layout=org.apache.log4j.patternlayout
log4j.appender.a1.layout.conversionpattern=%-d{yyyy-mm-dd hh:mm:ss,sss} [%c]-[%p] %m%n
此時你去執行 test-commons-logging.jsp 輸出的內容, 就會記錄在你的 c:\log 目錄的 test.log 中了 ps:如果沒有相關的 class 會使用到 simplog, 此時要設定的是
simplelog.properties 結論以我自己本身使用的經驗, log4j 可以滿足所有工程師, 所以我也是直接使用 log4j 而沒有使用 commons-logging.
不過為了增加產品的通用性, 避免移植時候的麻煩, 新的產品及項目, 我會將他改成 commons-logging api 去調用.
如果你對commons-logging的工作原理不是很了解，請參考＜commons-logging的使用方法＞
文章整理：
http://www.west263.com
package com.augurit.pysz.common.excelUtil;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import com.augur.wf.shark.common.Db.DbConnectionManager;
import com.augurit.pysz.common.excelUtil.model.TableValue;
/**
* 從hibernate中將table的表結構找出來。 imcb 2007.6.26
*/
public class RetrieveTableContext {
public Connection testDB() throws ClassNotFoundException, SQLException {
Connection con = null;
Class.forName("oracle.jdbc.driver.OracleDriver");
con = DriverManager.getConnection(
"jdbc:oracle:thin:@192.168.13.65:1521:pysz", "shark", "shark");
return con;
}
/**
* 通過表名查找表的英文名
*
* @param dbName數據庫實例名稱
* @return
*/
public List getAllTableName(String dbName) {
List ls = new ArrayList();
Connection con = null;
try {
// con = DbConnectionManager.getInstance().getConnection("idb");
con = this.testDB();
String sql = "select * from sys.all_tab_comments t where t.table_type = 'TABLE' and t.owner = '"+dbName+"'";
PreparedStatement psts = con.prepareStatement(sql);
ResultSet rs = psts.executeQuery();
int i=0;
while(rs.next()){
TableValue tv = new TableValue();
System.out.println(++i+"條 ：");
System.out.print(rs.getString(1)+" : ");
tv.setDbName(rs.getString(1));
System.out.print(rs.getString(2)+" : ");
tv.setTableName(rs.getString(2));
System.out.print(rs.getString(3)+" : ");
tv.setDbType(rs.getString(3));
System.out.println(rs.getString(4));
tv.setComment(rs.getString(4));
ls.add(tv);
}
} catch (Exception we) {
} finally {
DbConnectionManager.getInstance().freeConnection("idb", con);
}
return ls;
}
/**
* 通過表名查找表的英文名
*
* @param str1
* @param dbName數據庫實例名稱
* @return
*/
public String getTableName(String str1,String dbName){
String tableName = new String();
List ls = this.getAllTableName(dbName);
Iterator iterator =ls.iterator();
while(iterator.hasNext()){
TableValue tv =(TableValue)iterator.next();
boolean hasStr = tv.getComment().contains(str1);
if(hasStr)return tv.getTableName();
}
return tableName;
}
/**
* 通過表名查找數據表屬性值。
*
* @param tableName
* 表的英文名
* @return
*/
public List getTableContext(String tableName) {
List tList = new ArrayList();
return tList;
}
public static void main(String[] str1){
// RetrieveTableContext rtc = new RetrieveTableContext();
// rtc.getTableName("d","SHARK");
String u="string yu";
String in = "s";
String out = "e";
System.out.println(in.contains(in));//in是否包含in字符串
System.out.println(u.contains(out));
}
}