[code="java"]
private void execute(){
Statement st;
try {
//获取oracle链接
oracleCONN=getOracleConnection();
//获取MYSQL链接
st = oracleCONN.createStatement();
oracleRS=st.executeQuery("select bc.customerName,bc.landline,bc.telphone,sb.finishdate,sb.ShopCode,sb.DisCode from base_Customer bc,sale_SalesBill sb where trunc(bc.Created)=trunc(sysdate-1)and bc.saleBillid=sb.salesBillid");
String sql="insert into mix_end_user(name,tel,phone,time,officeName,storeName) values(?,?,?,?,?,?)";
mySQLCONN=getMYConnection();
ps = mySQLCONN.prepareStatement(sql);
// mySQLCONN.createStatement();
while(oracleRS.next()){
//开启事务
mySQLCONN.setAutoCommit(false);
ps.setString(1,oracleRS.getString("customerName"));
ps.setString(2, oracleRS.getString("landline"));
ps.setString(3, oracleRS.getString("telphone"));
ps.setDate(4, oracleRS.getDate("finishdate"));
ps.setString(5,oracleRS.getString("DisCode"));
ps.setString(6,oracleRS.getString("ShopCode"));
// System.out.println("insert into mix_end_user(name,tel,phone,time,officeName,storeName) values("+oracleRS.getString("customerName")+","+ oracleRS.getString("landline")+","+oracleRS.getString("telphone")+","+oracleRS.getDate("finishdate")+","+oracleRS.getString("DisCode")+","+oracleRS.getString("ShopCode")+")");
//提交
ps.executeUpdate();
mySQLCONN.commit();
}
} catch (SQLException e) {
e.printStackTrace();
//将异常信息写入配置文件
writeLOG(e);
try {
mySQLCONN.rollback();
} catch (Exception e1) {
e1.printStackTrace();
writeLOG(e);
}
}finally{
closeConnection();
}
}
[/code]
两个数据库 oracle取数据 mysql存数据
为什么回报这个错
com.mysql.jdbc.MysqlDataTruncation: Data truncation: Out of range value for column 'id' at row 1
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:2983)
at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:1631)
at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:1723)
at com.mysql.jdbc.Connection.execSQL(Connection.java:3256)
at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1313)
at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:1585)
at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:1500)
at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:1485)
at copy.user.CopyUser.execute(CopyUser.java:55)
at copy.user.CopyUser.main(CopyUser.java:25)