package com.zb.test;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import com.zb.bean.BackUpFileBean;
import com.zb.bean.BackUpRequestInfoBean;
import com.zb.util.DBManager;
import com.zb.util.Log;
public class Test {
/**
* @param args
*/
public void Test(){
System.out.println("backUpRequestID:----");
boolean flag = true;
Connection conn = DBManager.getConn();
System.out.println("backUpRequestID:555555555");
PreparedStatement pstmt = null;
System.out.println("backUpRequestID:333333");
Statement stmt = null;
//long backUpRequestId = getId();
//System.out.println("backUpRequestID:----"+backUpRequestId);
String sql = "insert into BACKUPREQUEST(BACKUPREQUESTID,DEPARTMENTUSERID,BACKUPREQUESTNAME,KEEPTIME" +
",REMARK,FILECOUNT,DEPARTMENTID,DEPARMENTNAME,BACKUPREQUESTSTATUS" +
",FILESIZE,FILEPATH,TASKID,BUILDTIME,DEPARTMENTUSERNAME,APPROVESTATUS,DISKORTAPE) " +
"values(99,?,?,?,?,?,?,?,?,?,?,?,?,?,?,0)";
System.out.println("sql add :" +sql);
try {
conn.setAutoCommit(false);
System.out.println("backUpRequestID:55fffffff5");
pstmt = conn.prepareStatement(sql);
//stmt = conn.createStatement();
System.out.println("backUpRequestID:56666555");
pstmt.setLong(1, 60);
pstmt.setString(2,"");
pstmt.setLong(3, 0l);
pstmt.setString(4,"");
pstmt.setLong(5, 0l);//in
pstmt.setLong(6,13);
pstmt.setString(7,"");
pstmt.setInt(8,0);
pstmt.setLong(9, 0l);//in
pstmt.setString(10,"");//in
pstmt.setString(11,"");//in
pstmt.setTimestamp(12,null);
pstmt.setString(13,"");
pstmt.setInt(14,0);
//pstmt.setInt(15,0);
int i = pstmt.executeUpdate();
System.out.println("e="+i);
//System.out.println("backUpRequestID:----"+backUpRequestId);
// 添加备份文件
//for(BackUpFileBean aBean:backUpRequestInfo.getList()) {
// sql = "insert into BACKUPFILE(FILEID,BACKUPREQUESTID,FILENAME,MODIFYTIME ,FILESIZE) " +
// "values(backupfile_seq.nextval,"+backUpRequestId+",'"+aBean.getFileName()+"'" +
// ",'"+aBean.getModifyTime()+"',"+aBean.getFileSize()+")";
// stmt.addBatch(sql);
//}
//int [] k = stmt.executeBatch();
//System.out.println("iii:"+k.length);
DBManager.commit(conn);
//if(i == 0 || k.length < 0) flag = false;
} catch (SQLException e) {
System.out.println("数据备份失败!sql Exception....."+e);
DBManager.rollback(conn);
Log.writeEvents(this.getClass(),"addBackUpRequestInfo", e.getMessage());
} finally {
DBManager.closePreparedStatement(pstmt);
DBManager.closeConnection(conn);
}
}
public long getId() {
String sql = "select backuprequest_seq.nextval ID from dual ";
long id = 0;
Connection conn = DBManager.getConn();
Statement stmt = null;
ResultSet rs = null;
try {
conn.setAutoCommit(false);
stmt = conn.createStatement();
rs = stmt.executeQuery(sql);
if(rs.next())
id = rs.getLong("ID");
DBManager.commit(conn);
} catch(SQLException e) {
DBManager.rollback(conn);
Log.writeEvents(this.getClass(),"deleteBackUpRequestInfo", e.getMessage());
}
catch(Exception e){System.out.println(e);}
finally {
DBManager.closeResultset(rs);
DBManager.closeStatement(stmt);
DBManager.closeConnection(conn);
}
return id;
}
public static void main(String[] args) {
// TODO Auto-generated method stub
System.out.println("asdfsad");
Test test1 = new Test();
test1.Test();
}
}