public ActionForward execute(
ActionMapping mapping,
ActionForm form,
HttpServletRequest request,
HttpServletResponse response) throws FileNotFoundException, IOException {
ImportElecForm fm = (ImportElecForm) form;
FormFile fj=fm.getFile();
String fname=fj.getFileName().toLowerCase();
if (!(fname.endsWith(".txt"))){
request.setAttribute("msg","您必须上传txt格式的数据文件");
return (new ActionForward("/setting/DataAccess.jsp"));
}
if (!(fj.getFileName().length()>1)){
request.setAttribute("msg","您必须上传的文件不包含数据!");
return (new ActionForward("/setting/DataAccess.jsp"));
}
InputStream sin=fj.getInputStream();
InputStreamReader isr=new InputStreamReader(sin,"GBK");
BufferedReader bfr=new BufferedReader(isr);
Connection con=null;
ResultSet rs=null;
HashMap courseIDs=new HashMap();
int TOTAL_COURSE=0;
StringBuffer sb_failed=new StringBuffer();
StringBuffer sb_success=new StringBuffer();
Session session=null;
try {
session=HibernateUtil.openSession();
con=DBM.getConnection();
Statement stmt=con.createStatement();
//StringTokenizer tokenizer = new StringTokenizer(outputText, "\n");
String line="";
while((line = bfr.readLine()) != null ){
User user=null;
String opcode="";
try{
StringTokenizer st = new StringTokenizer(line, ",");
String username=st.nextToken().trim();
String password=st.nextToken().trim();
//String RealName=new String(st.nextToken().getBytes("ISO8859_1"),"GBK");
//String Sex=new String(st.nextToken().getBytes("ISO8859_1"),"GBK");
String RealName=st.nextToken();
String Sex=st.nextToken();
String StuFlag=st.nextToken().trim();
String ZhuangT=st.nextToken().trim();
//String BeiZ=new String(st.nextToken().getBytes("ISO8859_1"),"GBK");
String BeiZ=st.nextToken();
String v1=st.nextToken().trim();
String v2=st.nextToken().trim();
String v3=st.nextToken().trim();
String role=st.nextToken().trim();
String sql="";
String sql2="";
String sql3="";
boolean uexist=true;
try {
user=(User)session.load(User.class,username);
} catch (HibernateException e) {
user=new User();
uexist=false;
user.setUsername(username);
}
user.setPassword(password);
user.setRealName(RealName);
user.setSex(Sex);
user.setStuFlag(new Integer(StuFlag));
user.setZhuangT(new Integer(ZhuangT));
user.setBeiZ(BeiZ);
if (StuFlag.equals("0")){
user.setWorkerId(v1);
user.setKem(v2);
user.setBum(v3);
//sql="update users set password='"+password+"',realname='"+RealName+"',sex='"+Sex+"',stuflag="+StuFlag+",zhuangt="+ZhuangT+",beiz='"+BeiZ+"',workerid='"+v1+"',kem='"+v2+"',bum='"+v3+"' where username='"+username+"'";
}else{
user.setStuId(v1);
user.setNianJdm(v2);
Stuclass stuclass=(Stuclass)session.load(Stuclass.class,v3);
user.setStuclass(stuclass);
//user.setBanJdm(v3);
//sql="update users set password='"+password+"',realname='"+RealName+"',sex='"+Sex+"',stuflag="+StuFlag+",zhuangt="+ZhuangT+",beiz='"+BeiZ+"',stuid='"+v1+"',nianjdm='"+v2+"',banjdm='"+v3+"' where username='"+username+"'";
}
//System.out.println(sql);
try {
HibernateUtil.beginTransaction();
if (uexist){
opcode="[更新] ";
session.update(user);
}else {
session.save(user);
}
HibernateUtil.commitTransaction();
}catch(Exception e){
e.printStackTrace();
}
/*
try {
stmt.execute("insert into users (username) values('"+username+"');");
}catch(SQLException se){
opcode="[更新] ";
//se.printStackTrace();
}
stmt.execute(sql);
*/
try {
sql3="delete from userrole where username='"+username+"'";
sql2="insert into userrole (username,roleid) values('"+username+"','"+role+"')";
stmt.execute(sql3);
stmt.execute(sql2);
}catch(SQLException se){
}
//sb_success.append(new String(line.getBytes("ISO8859_1"),"GBK"));
sb_success.append(opcode);
sb_success.append(line);
sb_success.append("<br>");
}catch(Exception e){
//sb_failed.append(new String(line.getBytes("ISO8859_1"),"GBK"));
sb_failed.append(opcode);
sb_failed.append(line);
sb_failed.append("<br>");
e.printStackTrace();
}
}
}catch(Exception e){
e.printStackTrace();
}finally{
if (rs!=null)
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
if (con!=null) DBM.freeConnection(con);
try {
HibernateUtil.closeSession();
} catch (HibernateException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
fj.destroy();
try {
Syslog log=new Syslog();
log.setCreateTime(EC.getDateTime());
log.setIp(request.getRemoteAddr());
log.setUsername((String)request.getSession().getAttribute("username"));
log.setDetail("");
log.setLogType("导入用户");
EC.addLog(log);
} catch (HibernateException e) {
e.printStackTrace();
}
request.setAttribute("success",sb_success.toString());
request.setAttribute("failed",sb_failed.toString());
return new ActionForward("/setting/ImportUserState.jsp");
//return (new ActionForward("/setting/DataAccess.jsp"));
}
分享到:
相关推荐
java 导入Excel 文件,兼容Excel 2003(后缀名:xls)及 2007(后缀名:xlsx)的文件,同时还支持csv格式的文件
里面没包 只有几个主要的类。。。 主要是怕以后忘记,先保存下来而以 java导入txt到数据库 从数据库导出txt
工作中有很多数据以txt方式存储,需要导入oracle数据库处理(方便进行计算、统计),因文件较多,不便于手工处理,所以编写此程序以便进行数据导入。已经测试过,可以将数据导入oracle。
从TXT文件数据导入到mysql数据库,有相关解析示例TXT文件,然后根据情况插入到数据库表中去。
Java把txt文件导入SqlServer中
本范例是用Objects Java为iserver实现的一个扩展功能:在服务端实时的将TXT中的点数据更新到工作空间下,并将这些点数据发布为rest地图服务。
java实现页面导入excel文件,保存excel文件到数据库,有需要在页面上导入一个excel表的同学可以借鉴
txt中信息例如:姓名、年龄、年级、学号等信息通过java程序导入到SQL数据库中
java 读取txt文本文件中的数据并保存到数据库中源代码,假设txt已有格式,并以","分隔。其中的sql包需要自己去微软官网下载。
在生产企业中,会涉及到许多诸如把外部文件内容导入到数据库。本资源采用java程序开发,文本文件内容里的字段用“,”分开(如果是其他标识符,相应修改一下就行了),方便快捷。
为了实现R语言文本挖掘,所需的csv格式文件,利用Java 将文本文件写成csv格式的文件;文本文件的存放结构为---example ---class1 t1.txt ... ---class2 f1.txt ...
使用java导出tet文件的几种方法 使用ava把数据库中的数据导入TXT
利用java图形化界面和网络编程相结合实现的--文件上传。 运行步骤: (1)分别运行工程两个包中的两个.java文件(UploadClient.java和UploadServer.java)分别会弹出“上传客服端”和“上传服务器”两个窗口。 ...
批量读取txt文件导入到数据库中,批量读取txt文件导入到数据库中 批量读取txt文件导入到数据库中,批量读取txt文件导入到数据库中
TXT文件导入到数据库.
搭建SSH框架,利用JSP前台调用Action类中的方法,从数据库读出数据,导出TXT文件和Excel文件。TXT文件导出只用到流操作。导出Excel文件利用apache的poi第三方包,可在阿帕奇官网下载(最新版本为3.8,支持office2010...
java 写的可以把表格转换为导入Trados的txt文件的小工具
POI导入Excel并返回校验后的错误文件(原样数据文件,并添加批注,注:由于批注只能加1000条,会在Excel后面添加一栏错误信息)下载以及页面展示校验错误信息,同时添加导入进度条,提供页面js和css代码,后端...
将 LDIF 文件导入 LDAP 服务器.txt
在将jar包放到另外一台机器中运行时,往往缺少调用库所需要的dll或者...实现将dll文件导入java工程,dll导入jar包,解决 no dll文件 in java.library.path问题,不用手动将dll复制到system32中,也不用新增依赖的库。