首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > JAVA > J2SE开发 >

急请教怎么进行循环插入数据库呀

2012-01-08 
急!!!请问如何进行循环插入数据库呀!while(rs5.next()){Stringidrs5.getString( id )//(NOTNULL)Strin

急!!!请问如何进行循环插入数据库呀!
while(rs5.next())
{
String   id=rs5.getString( "id ");   //(NOT   NULL)
String   unitid=rs5.getString( "unitid ");
if(unitid==null)
      unitid= " ";
String   unitname=rs5.getString( "unitname ");
if(unitname==null)
      unitname= " ";
String   name=rs5.getString( "name ");
if(name==null)
      name= " ";
String   sex=rs5.getString( "sex ");
if(sex==null)
      sex= " ";
String   folkcode=rs5.getString( "folkcode ");
if(folkcode==null)
      folkcode= " ";
String   birth=rs5.getString( "birth ");
if(birth==null)
      birth= " ";
String   personcode=rs5.getString( "personcode ");
if(personcode==null)
      personcode= " ";
String   duty=rs5.getString( "duty ");
if(duty==null)
      duty= " ";
String   politycode=rs5.getString( "politycode ");
if(politycode==null)
      politycode= " ";
String   degreecode=rs5.getString( "degreecode ");
if(degreecode==null)
      degreecode= " ";
String   post=rs5.getString( "post ");
if(post==null)
      post= " ";
String   workcode=rs5.getString( "workcode ");
if(workcode==null)
      workcode= " ";
String   officetel=rs5.getString( "officetel ");
if(officetel==null)
      officetel= " ";
String   hometel=rs5.getString( "hometel ");
if(hometel==null)
    hometel= " ";
String   movetel=rs5.getString( "movetel ");
if(movetel==null)
      movetel= " ";
String   notes=rs5.getString( "notes ");
if(notes==null)
      notes= " ";
conn5.close();
String   sql= "insert   into   sec_bwglry   (id,unitid,unitname,name,sex,folkcode,birth,personcode,duty,politycode,degreecode,post,workcode,officetel,hometel,movetel,notes) "+ "values( ' "+bwglid+ " ', ' "+unitid+ " ', ' "+unitname+ " ', ' "+name+ " ', ' "+sex+ " ', ' "+folkcode+ " ', ' "+birth+ " ', ' "+personcode+ " ', ' "+duty+ " ', ' "+politycode+ " ', ' "+degreecode+ " ', ' "+post+ " ', ' "+workcode+ " ', ' "+officetel+ " ', ' "+hometel+ " ', ' "+movetel+ " ', ' "+notes+ " ') ";
try
{
Connection   conn=   DriverManager.getConnection(url,user,password);
Statement   stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
stmt2.executeUpdate(tmp2);
conn2.close();
}
catch(SQLException   e)
{
out.print( "SQL异常! ");
}
用这样的处理后,只能向数据库了增加一条记录!!
谢谢,给出具体点的说明!

[解决办法]
public int insertT_KSLKYTHND(ShowDetaileEntDAOData data) throws DAOException {
if (log.isTraceEnabled()) {
log.trace( "entering ShowDetaileEntDAO.insertT_KSLKYTHND() ");
}


String createSql = getInsertT_KSLKYTHNDSql(data);
PreparedStatement stmt = null;
int retNo = 0;
try {
String realSql = rdbmsStrategy.convertInsertSql(createSql, ShowDetaileEntDAO.class, "insertT_KSLKYTHND ");
if (log.isDebugEnabled()) {
log.debug(realSql);
}
stmt = getConnection().prepareStatement(realSql);
JDBCUtil.setTimestamp(stmt, 1, data.getCREATED_DATE());
JDBCUtil.setString(stmt, 2, data.getCREATED_BY(), rdbmsStrategy);
JDBCUtil.setString(stmt, 3, data.getCREATED_PRG_NM(), rdbmsStrategy);
JDBCUtil.setTimestamp(stmt, 4, data.getUPDATED_DATE());
JDBCUtil.setString(stmt, 5, data.getUPDATED_BY(), rdbmsStrategy);
JDBCUtil.setString(stmt, 6, data.getUPDATED_PRG_NM(), rdbmsStrategy);
JDBCUtil.setString(stmt, 7, data.getCOR_CDE(), rdbmsStrategy);
JDBCUtil.setString(stmt, 8, data.getTAN_CDE(), rdbmsStrategy);
JDBCUtil.setString(stmt, 9, data.getNEW_KYT_CDE(), rdbmsStrategy);
JDBCUtil.setString(stmt, 10, data.getNEW_KYT_NAM_SEI(), rdbmsStrategy);
JDBCUtil.setString(stmt, 11, data.getNEW_KYT_NAM_RYK(), rdbmsStrategy);
JDBCUtil.setString(stmt, 12, data.getNEW_BMN_CDE(), rdbmsStrategy);
JDBCUtil.setString(stmt, 13, data.getNEW_BMN_NAM_SEI(), rdbmsStrategy);
JDBCUtil.setString(stmt, 14, data.getNEW_BMN_NAM_RYK(), rdbmsStrategy);
JDBCUtil.setString(stmt, 15, data.getNEW_YKO_SDY(), rdbmsStrategy);
JDBCUtil.setString(stmt, 16, data.getGEN_KYT_CDE(), rdbmsStrategy);
JDBCUtil.setString(stmt, 17, data.getGEN_KYT_NAM_SEI(), rdbmsStrategy);
JDBCUtil.setString(stmt, 18, data.getGEN_KYT_NAM_RYK(), rdbmsStrategy);
JDBCUtil.setString(stmt, 19, data.getGEN_BMN_CDE(), rdbmsStrategy);
JDBCUtil.setString(stmt, 20, data.getGEN_BMN_NAM_SEI(), rdbmsStrategy);
JDBCUtil.setString(stmt, 21, data.getGEN_BMN_NAM_RYK(), rdbmsStrategy);
JDBCUtil.setString(stmt, 22, data.getGEN_YKO_SDY(), rdbmsStrategy);
long startTime = 0;
if (log.isInfoEnabled()) {
startTime = System.currentTimeMillis();
}
retNo = stmt.executeUpdate();
if (log.isInfoEnabled()) {
long finishTime = System.currentTimeMillis();
log.info( "elapsed time: " + (finishTime - startTime) + "ms ");
}
if (log.isDebugEnabled()) {
log.debug( "insertT_KSLKYTHND: inserted count: " + retNo);
}
} catch (SQLException ex) {
throw new DAOException( "SQLException occured. ", ex);
} finally {
JDBCUtil.closeAll(stmt);
}
if (log.isTraceEnabled()) {
log.trace( "exiting ShowDetaileEntDAO.insertT_KSLKYTHND() ");
}
return retNo;
}
*******************************************************
public LogicData execute(AP01LogicData inputLogicData)throws LogicException {
Transaction tx = getTransaction();
int i = 0;
try {
for (i = 0; i < intDetailsSize; i++) {
objApDao.insertT_KSLKYTHND(daoDataInput);
}
tx.commit();
ret.setERROR( "success ");
} catch (Exception t) {
int intExceptionType = DBUtil.getExceptionType(t);
switch (intExceptionType) {
case ConstantUtil.UNIQUE_ERR:
ret.setERROR( "unique_error ");
ret.setRowNo(String.valueOf(i));


break;
default:

ret.setERROR( "error ");
LogicUtil.throwWrappedLogicException(t);
break;
}
} finally {
if (tx.isTransactionActive()) {
tx.rollback();
}
}
return ret;
}

*********************************************************************************
只是一个思路,具体方法自己干!

热点排行