Excel数据读写到sql

package com.company.dao; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.Iterator; import java.util.List; import com.company.common.ConnectDatabase; import jxl.Cell; import jxl.Sheet; import jxl.Workbook; import jxl.read.biff.BiffException; import jxl.write.Label; import jxl.write.WritableSheet; import jxl.write.WritableWorkbook; import jxl.write.WriteException; import jxl.write.biff.RowsExceededException; public class IntoSqlDAOImpl implements IntoSqlDAO { public boolean into(String url, String tablename) { boolean sign=false; try { InputStream is = new FileInputStream(url); Workbook wb = Workbook.getWorkbook(is); Sheet st = wb.getSheet(0); System.out.println("该表含有" + st.getRows() + "行"); System.out.println("该表含有" + st.getColumns() + "列"); boolean frist_o = true, frist_s = true; int sum = 0; String[] a = new String[st.getColumns() + 2]; for (int j = 1; j < st.getRows(); j++) { for (int i = 0; i < st.getColumns(); i++) { if (frist_o) { System.out.println("开始读数据..."); frist_o = false; } Cell cell = st.getCell(i, j); String contents = cell.getContents().trim(); a[0] = "insert into " + tablename + " values("; a[st.getColumns() + 1] = ")"; a[i + 1] = contents; } if (a.length != 0) { if (frist_s) { System.out.println("开始把数据写入数据库..."); } ConnectDatabase conn = new ConnectDatabase(); Statement stmt = conn.createStatement(); System.out.println("开始拼接SQL语句..."); StringBuffer vec = new StringBuffer(); if (a.length != 0) { for (int n = 0; n < a.length; n++) { if (n == 0) { vec.append(a[n]); } if (0 < n && n <= a.length - 2) { if (0 < n && n < a.length - 2) { vec.append("'" + a[n] + "'" + ","); } else { vec.append("'" + a[n] + "'"); } } if (n == a.length - 1) { vec.append(a[n]); } } } String sql = vec.toString(); System.out.println(sql); int rs = stmt.executeUpdate(sql); sign=true; conn.closeConn(); System.out.println("关闭数据库..."); System.out.println("写入数据库成功！数据库已经关闭！"); sum++; } } System.out.println("写入数据库完毕！"); System.out.println("一共有" + sum + "条数据写入到服务器！"); wb.close(); is.close(); System.out.println("操作成功！"); } catch (FileNotFoundException e) { System.out.println("文件目录不存在！"); sign = false; e.printStackTrace(); } catch (BiffException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } return sign; } }