首页 > 学院 > 开发设计 > 正文

POI遍历Excle表

2019-11-11 05:18:36
字体:
来源:转载
供稿:网友

最近一个哥哥给我出了一个题目:用POI把Excle表的数据插入到数据库中。

下面是我做的:

明确两点。1.读取Excel表的数据

2.连接数据库(Oracle)并插入数据

1。首先Maven导包:我是从csdn下的,然后用    mvn install:install-file -Dfile= -DgroupId= -DartifactId= -Dversion= -Dpackaging=jar 命令将包导入本地Maven仓库。

2。第二步连接数据库:也是从csdn下的Oracle的数据源用Maven命令导入本地仓库

   

下面是连接数据并插入数据的相关代码:

public class DBHelper {	PRivate Connection conn = null;	private PreparedStatement pstmt = null;	private ResultSet rs = null;		static{		try{   	    //加载MySQL的驱动类   	    Class.forName("oracle.jdbc.driver.OracleDriver") ;   	    }catch(ClassNotFoundException e){   	    System.out.println("找不到驱动程序类 ,加载驱动失败!");   	    e.printStackTrace() ;   	   }	}		public Connection getConnection(){		try {//			DataSource dataSource=(DataSource)BasicDataSourceFactory.createDataSource(Env.getInstance());//			Context context=new InitialContext();//			DataSource dataSource=(DataSource)context.lookup("java:comp/env/jdbc/orcl");			conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl" , "wb" , "a" ) ;		} catch (Exception e) {				e.printStackTrace();			}		return conn;	}	/**	 * 字符转换	 * 	 * @param pstmt	 *           	 * @param params	 *           	 * @throws SQLException	 */	public void setValue(PreparedStatement pstmt, List<Object> params)			throws SQLException {		// 字符转换		if (params != null && params.size() > 0) {			Object obj = null;			String type = "";			for (int i = 0; i < params.size(); i++) {				obj = params.get(i);				if (obj != null) {					type = obj.getClass().getName();					if ("[B".equals(type)) {						pstmt.setBytes(i + 1, (byte[]) obj);					} else {						pstmt.setString(i + 1, String.valueOf(obj));					}				} else {					pstmt.setString(i + 1, String.valueOf(obj));				}			}		}	}	/**	 * 更新数据	 * 	 * @param sql	 *           	 * @param params	 *           	 * @return	 */	public int update(String sql, List<Object> params) {		int result = 0;		try {			conn = this.getConnection();			pstmt = conn.prepareStatement(sql);//预处理			this.setValue(pstmt, params);			result = pstmt.executeUpdate(); // 执行sql语句		} catch (SQLException e) {			e.printStackTrace();		}		return result;	}3.连接数据库成功后,就是用Apache软件基金会的开放源码函式库,也就是POI来读取Excle表格的数据:

代码如下:

package com.jjz.util;import java.io.FileInputStream;import java.io.IOException;import java.util.Iterator;import org.apache.poi.hssf.usermodel.HSSFCell;import org.apache.poi.hssf.usermodel.HSSFWorkbook;import org.apache.poi.ss.usermodel.Cell;import org.apache.poi.ss.usermodel.Row;import org.apache.poi.ss.usermodel.Sheet;import org.apache.poi.ss.usermodel.Workbook;import org.apache.poi.xssf.usermodel.XSSFWorkbook;public class Ddl {	private Workbook wb;	private FileInputStream fis;	private DBHelper db ;	public Workbook createWorkbook(String filePath) throws IOException{		if(filePath != null){			fis = new FileInputStream(filePath);			if(filePath.endsWith(".xls")){				//2003版本的excel,用.xls结尾				wb = new HSSFWorkbook(fis);//得到工作簿			}else if(filePath.endsWith(".xlsx")){				 //2007版本的excel,用.xlsx结尾				wb = new XSSFWorkbook(fis);//得到工作簿			}else{			}			return wb;		}		return null;	}	/**	 * 第一种遍历方式:纯粹的for循环	 * @param wbk	 */	public void insert2DataBase(Workbook wbk){		db = new DBHelper();		StringBuffer sql;		if(wbk != null){			Sheet sheet = wbk.getSheetAt(0);			Row row;			Cell cell = null;			if(sheet != null){				for(int i = 1; i < sheet.getPhysicalNumberOfRows(); i ++){					sql = new StringBuffer("insert into test (Tid, Tname) values ");					row = sheet.getRow(i);										String bh = "";					String xm = "";					for(int j = 0; j < row.getPhysicalNumberOfCells(); j ++){						cell = row.getCell(j);						switch(cell.getCellType()){						case HSSFCell.CELL_TYPE_NUMERIC: // 数字  	                        sql.append("(").append( String.valueOf((int)cell.getNumericCellValue()) ).append(",");  	                        bh = String.valueOf((int)cell.getNumericCellValue());	                        break;  	                    case HSSFCell.CELL_TYPE_STRING: // 字符串  	                    	sql.append("'").append( cell.getStringCellValue() ).append("')");  	                    	xm = cell.getStringCellValue();	                    	break;  	                    /*case HSSFCell.CELL_TYPE_BOOLEAN: // Boolean  	                        cellValue = cell.getBooleanCellValue() + "";  	                        break;  	                    case HSSFCell.CELL_TYPE_FORMULA: // 公式  	                        cellValue = cell.getCellFormula() + "";  	                        break;  	                    case HSSFCell.CELL_TYPE_BLANK: // 空值  	                        cellValue = "";  	                        break; 	                    case HSSFCell.CELL_TYPE_ERROR: // 故障  	                        cellValue = "非法字符";  	                        break;  */ 	                    default:  	                        break; 	                    } 						}					int result = db.update(sql.toString(), null);					if(result > 0){ 						System.out.println("数据插入成功:" + sheet.getRow(0).getCell(0).toString()+ "=" + bh + "," + sheet.getRow(0).getCell(1).toString() + "=" +xm);					}				}			}		}	}		/**	 * 换一种遍历方式	 * @param wb	 */	public void doSomething(Workbook wb){		if(wb != null){			Sheet sheet;			Row row;			//一个工作簿可能不止一个sheet表格			for(int i = 0; i < wb.getNumberOfSheets(); i ++){				sheet = wb.getSheetAt(i);				//循环遍历每个sheet表的没行数据				for(int j = 1; j < sheet.getPhysicalNumberOfRows(); j ++){					row = sheet.getRow(j);					//用迭代遍历,因为我看见它有一个iterator()方法					for(Iterator<Cell> cell = row.iterator(); cell.hasNext() ;){						System.out.print( cell.next().toString() + "  ");					}					System.out.println();				}			}		}	}}4.两部合并,谢了测试代码:

package com.jjz.poi;import java.io.IOException;import org.apache.poi.ss.usermodel.Workbook;import com.jjz.util.Ddl;public class WbTest {	public static void main(String[] args) {		Ddl ddl = new Ddl();		Workbook wb = null;		try {			wb = ddl.createWorkbook("C://Users//Administrator//Desktop//test.xls");		} catch (IOException e) {			e.printStackTrace();		}				if(wb != null){			ddl.insert2DataBase(wb);						ddl.doSomething(wb);		}			}	}

发现数据库中插入了数据:

控制台输出了如下数据:

发现可行。

总结:

个人发现这样写有很大的一个弊端就是插入数据的时候,每读取一行数据就把它插入到数据库。这样要频繁写重复的sql语句去的跟新(插入)数据库。麻烦(因为不是MySql数据库)。可以写一个事务,一次性插入,要么成功,要么失败后回滚。还有一点就是对于数据的处理可以写一个People类,表格中的第一和第二两列的属性作为它的变量,有点像Springmvc从jsp页面传对象过来一样,用它来传值。不知道行不行,QAQ。总之,这一段程序缺点多多。


发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表