实现的功能:

  • 用Java实现从Excel导入数据库,如果存在就更新
  • 将数据库中的数据导出为Excel

1、添加jxl.jar mysql-connector-java.1.7-bin.jar包到项目的lib目录下­

2、Excel文件目录:D://book.xls

3、数据库名:Stu

4、表名:student

5、编写类:连接mysql的字符串方法、插入的方法、实体类­­

表结构如下 :

连接数据库的工具类

DBhelper.java

package com.cn.gao;
import java.sql.*;
public class DBhelper {
Connection conn = null;
ResultSet rs = null;
//连接数据库
public void connect(){
try {
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/Stu","root","1234");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
// e.printStackTrace();
System.out.println("数据库驱动加载失败!");
} catch (SQLException e) {
// TODO Auto-generated catch block
// e.printStackTrace();
System.out.println("数据库连接失败!");
} } //查询
public ResultSet Search(String sql, String str[]){
connect();
try {
PreparedStatement pst = conn.prepareStatement(sql);
if(str != null){
for(int i=0;i<str.length-1;i++){
pst.setString(i+1, str[i]);
}
pst.setInt(str.length, Integer.parseInt(str[str.length-1]));
}
rs = pst.executeQuery();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return rs;
} //增删修改
public int AddU(String sql, String str[]){
int a =0;
connect();
try {
PreparedStatement pst = conn.prepareStatement(sql);
if(str != null){
for(int i=0;i<str.length-1;i++){
pst.setString(i+1, str[i]);
}
pst.setInt(str.length, Integer.parseInt(str[str.length-1]));
}
a = pst.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return a;
} }

表的实体如下

Stu.java

package com.cn.gao;
//学生实体类
public class Stu {
private int id;
private String name;
private String sex;
private int num; public Stu(){ } public Stu(int id,String name,String sex,int num){
this.id = id;
this.name = name;
this.sex = sex;
this.num = num;
} public String toString(){
return "Stu[id="+id+", name="+name+", sex="+sex+", num="+num+"]";
} public int getId() {
return id;
} public void setId(int id) {
this.id = id;
} public String getName() {
return name;
} public void setName(String name) {
this.name = name;
} public String getSex() {
return sex;
} public void setSex(String sex) {
this.sex = sex;
} public int getNum() {
return num;
} public void setNum(int num) {
this.num = num;
}
}

Java实现将Excel导入数据库的核心类 读取Excel表中所有的数据、操作数据(查询、更新)

StuService.java

package com.cn.gao;

import java.io.File;
import java.io.IOException;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List; import jxl.Sheet;
import jxl.Workbook;
import jxl.read.biff.BiffException; //实现Excel导入数据库核心类,读取Excel表中所有的数据,操作数据(查询、更新)
public class StuService {
/**
* 查询数据库中Student表中所有的数据
*/
public static List<Stu> getAllByDb(){
List<Stu> list = new ArrayList<Stu>();
DBhelper db = new DBhelper();
String sql = "select * from student";
ResultSet rs = db.Search(sql, null);
try {
while(rs.next()){
int id = rs.getInt("id");
String name = rs.getString("name");
String sex = rs.getString("sex");
int num = rs.getInt("num");
list.add(new Stu(id,name,sex,num));
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return list;
}
/**
* 查询指定目录中Excel表格中所有数据
* @param file为文件完整路径
* @return
*/
public static List<Stu> getAllByExcel(String file){
List<Stu> list = new ArrayList<Stu>();
try {
Workbook rwb = Workbook.getWorkbook(new File(file));
Sheet rs = rwb.getSheet("Test Shee 1"); //或者rwb.getSheet(0)
int clos=rs.getColumns();//得到所有的列
int rows=rs.getRows();//得到所有的行
System.out.println("clos:"+clos+" rows:"+rows);
for(int i=1;i<rows;i++){
int j=0;
//第一个是列数,第二个是行数
String id=rs.getCell(j++, i).getContents();//默认最左边编号也算一列 所以这里得j++
String name=rs.getCell(j++, i).getContents();
String sex=rs.getCell(j++, i).getContents();
String num=rs.getCell(j++, i).getContents(); System.out.println("id:"+id+" name:"+name+" sex:"+sex+" num:"+num);
list.add(new Stu(Integer.parseInt(id), name, sex, Integer.parseInt(num)));
}
} catch (BiffException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return list;
} /**
* 通过id判断是否存在
* @param id
* @return
*/
public static boolean isExist(int id){
try {
DBhelper db=new DBhelper();
ResultSet rs=db.Search("select * from student where id=?", new String[]{id+""});
if (rs.next()) {
return true;
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return false;
} public static void main(String[] args) {
/*List<Stu> all=getAllByDb();
for (Stu stuEntity : all) {
System.out.println(stuEntity.toString());
}*/ System.out.println(isExist(1)); }
}

将数据库中的数据导出到Excel表

FromDbToExcel.java

package com.cn.gao;

import java.io.File;
import java.util.List; import jxl.Workbook;
import jxl.write.Label;
import jxl.write.WritableSheet;
import jxl.write.WritableWorkbook; public class FromDbToExcel {
public static void main(String[] args) {
try {
WritableWorkbook wwb = null; // 创建可写入的Excel工作簿
String fileName = "D://book.xls";
File file=new File(fileName);
if (!file.exists()) {
file.createNewFile();
}
//以fileName为文件名来创建一个Workbook
wwb = Workbook.createWorkbook(file); // 创建工作表
WritableSheet ws = wwb.createSheet("Test Shee 1", 0); //查询数据库中所有的数据
List<Stu> list= StuService.getAllByDb();
//要插入到的Excel表格的行号,默认从0开始
Label labelId= new Label(0, 0, "编号(id)");//表示第
Label labelName= new Label(1, 0, "姓名(name)");
Label labelSex= new Label(2, 0, "性别(sex)");
Label labelNum= new Label(3, 0, "薪水(num)"); ws.addCell(labelId);
ws.addCell(labelName);
ws.addCell(labelSex);
ws.addCell(labelNum);
for (int i = 0; i < list.size(); i++) { Label labelId_i= new Label(0, i+1, list.get(i).getId()+"");
Label labelName_i= new Label(1, i+1, list.get(i).getName());
Label labelSex_i= new Label(2, i+1, list.get(i).getSex());
Label labelNum_i= new Label(3, i+1, list.get(i).getNum()+"");
ws.addCell(labelId_i);
ws.addCell(labelName_i);
ws.addCell(labelSex_i);
ws.addCell(labelNum_i);
} //写进文档
wwb.write();
// 关闭Excel工作簿对象
System.out.println("数据导出成功!");
wwb.close(); } catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

将Excel表中的数据导入到MySql数据库

FromExcelToDb.java

package com.cn.gao;

import java.util.List;

public class FromExcelToDb {
public static void main(String[] args) {
//得到表格中所有的数据
List<Stu> listExcel=StuService.getAllByExcel("d://book.xls");
/*//得到数据库表中所有的数据
List<Stu> listDb=StuService.getAllByDb();*/ DBhelper db=new DBhelper(); for (Stu stuEntity : listExcel) {
int id=stuEntity.getId();
if (!StuService.isExist(id)) {
//不存在就添加
String sql="insert into student (name,sex,num) values(?,?,?)";
String[] str=new String[]{stuEntity.getName(),stuEntity.getSex(),stuEntity.getNum()+""};
db.AddU(sql, str);
}else {
//存在就更新
String sql="update student set name=?,sex=?,num=? where id=?";
String[] str=new String[]{stuEntity.getName(),stuEntity.getSex(),stuEntity.getNum()+"",id+""};
db.AddU(sql, str);
}
}
System.out.println("数据更新成功!");
}
}

最新文章

  1. 关于js中变量声明和作用域的理解
  2. 在用的vim插件
  3. 使用 Swagger UI 与 Swashbuckle 创建 RESTful Web API 帮助文件
  4. php手册总结《安装与配置》
  5. UDP编程(八)
  6. error BC31019 无法写入输出文件 未指定错误
  7. express4.0之后不会解析req.files,必须加一个插件multer
  8. Redis系列三(redis配置文件分析)
  9. mac idea中的Application Server was not connected before run configuration stop, reason: Unable to ping server at localhost:1099问题
  10. 使用npm私有服务器保存公司内部强业务类型组件(一):npm私有服务器搭建
  11. Beta冲刺(4/5)(麻瓜制造者)
  12. udev简述
  13. BlueMind 3.0.17 发布,消息和协作平台
  14. Extjs gridPanel 动态指定表头
  15. JS获取客户端系统当前时区
  16. 由UI刷新谈到线程安全和Android单线程模型
  17. JVM虚拟机(五):JDK8内存模型—消失的PermGen
  18. 一款基于css3鼠标经过圆形旋转特效
  19. elasticsearch关于索引切分的实现
  20. [转]SIGPIPE信号

热门文章

  1. hdoj1171 Big Event in HDU(01背包 || 多重背包)
  2. 全面兼容的Iframe 与父页面交互操作
  3. Oracle数据库DDL,DML,视图,PLSQL编程
  4. JAVAEE——宜立方商城11:sso登录注册功能实现、通过token获得用户信息、Ajax跨域请求(jsonp)
  5. 使用DNSPod域名解析
  6. 使用gSOAP工具生成onvif框架代码
  7. 数据库中drop、delete与truncate的区别
  8. 【动态规划+Floyd】OpenJudge3368
  9. python 中__name__ = &#39;__main__&#39; 的作用,到底干嘛的?
  10. kali下利用weeman进行网页钓鱼