Oracle 插入超4000字节的CLOB字段的处理方法
2017-06-15 17:58
549 查看
在通过拼组sql语句来实现数据插入的应用中,我们很有可能会遇到需要插入大型数据的情况,例如,在oracle中需要插入字节数超过4000的字段内容时,我们如果通过简单的拼组sql语句来实现插入,显然就会出现问题,而在sql server中却没有这个限制,个人尝试了26w个字符的sql语句在sql server2005中执行,依旧可以插入数据,但是在oracle中插入超过4000个字符的内容则会报异常。
下面就此问题的解决办法,做一下小结:
我们可以通过创建单独的OracleCommand来进行指定的插入,即可获得成功,这里仅介绍插入clob类型的数据,blob与此类似,这里就不介绍了,下面介绍两种办法,均已验证:
第一种方法(单条处理):使用组件System.Data.OracleClient的方法来实现,比较简单一些:
string conn = "Data Source=客户端指定连接字符串;User ID=user;Password=mima";
OracleConnection Con = new System.Data.OracleClient.OracleConnection(conn);
Con.Open();
string cmdText = "INSERT INTO GWEXPOINTLIST(id, name, content) VALUES(1, ‘name', :clob)";
OracleCommand cmd = new OracleCommand(cmdText, Con);
OracleParameter op = new OracleParameter("clob", OracleType.Clob);
op.Value = "超过4000字符的超常字符串";
cmd.Parameters.Add(op);
cmd.ExecuteNonQuery();
Con.Close();
第二种方法[b](单条处理):使用组件Oracle.DataAccess的方法实现,可能用法稍微老了一些,但依然有效:[/b]
IDbCommand m_objCmd = new OracleCommand();
m_objCmd.CommandText = "INSERT INTO GWEXPOINTLIST(id, name, content) VALUES(1, ‘name', :clob)";
IDataParameterCollection m_arrParamter = m_objCmd.Parameters;
OracleClob clob = new OracleClob((OracleConnection)m_objConn);
OracleParameter objParam = new OracleParameter(‘clob', OracleDbType.Clob, clob, ParameterDirection.Input);
objParam.Value = "超过4000字符的超常字符串";
m_arrParamter.Insert(0, objParam);
int nRet = m_objCmd.ExecuteNonQuery();
当然,sql server同样也可以通过这样的方法来进行添加字符串,但是添加二进制文件的话,就只能用这种方式来添加了,因为需要读取文件的二进制流内容。
第三种方法(单条处理):比较简单
pstmt.setCharacterStream(4, new StringReader(map.get("TEMPLATE_INFO")), map.get("TEMPLATE_INFO").length());
map.get("TEMPLATE_INFO")就是那个超长的字符串
第四种方法(批处理)org.springframework.jdbc.core.JdbcTemplate:
public static int insert(final JT_po[] sqlArray) throws Exception {
String sql="insert into JT_pojo(id,title,Newstime,Onclick,Titleurl,Newtext,Newstype) values(?,?,?,?,?,?,?)";
try{
// getJdbcTemplate() 获取的是JdbcTemplate
int[] ii =getJdbcTemplate().batchUpdate(sql, new BatchPreparedStatementSetter(){
public void setValues(PreparedStatement ps, int i)
throws SQLException {
JT_po jt= sqlArray[i];
ps.setString(1,jt.getId());
ps.setString(2,jt.getTitle());
ps.setString(3,jt.getNewstime());
ps.setString(4,jt.getOnclick());
ps.setString(5,jt.getTitleurl());
ps.setString(6,jt.getNewstext());
ps.setString(7,jt.getAllcount());
}
@Override
public int getBatchSize() {
return sqlArray.length;
}
});
return ii.length;
}catch (org.springframework.dao.DataAccessException e) {
e.printStackTrace();
}
return 0;
}
第五种方法(批处理)java.sql.PreparedStatement
public boolean insertggpt(String dsname, JT_po[] sqlArray) {
Connection conn = null;
PreparedStatement ps = null;
String sql="insert into JT_pojo(id,title,Newstime,Onclick,Titleurl,Newtext,Newstype) values(?,?,?,?,?,?,?)";
try{
conn = getConnection(dsname);
if (conn!=null && !conn.isClosed()) {
ps = conn.prepareStatement(sql);
//优化插入第一步 设置手动提交
conn.setAutoCommit(false);
for(int i=0; i<sqlArray.length; i++) {
JT_po jt= sqlArray[i];
ps.setString(1,jt.getId());
ps.setString(2,jt.getTitle());
ps.setString(3,jt.getNewstime());
ps.setString(4,jt.getOnclick());
ps.setString(5,jt.getTitleurl());
ps.setString(6,jt.getNewstext());
ps.setString(7,jt.getAllcount());
ps.addBatch();
}
ps.executeBatch();
conn.commit();
ps.clearBatch(); //提交后,Batch清空。
}
} catch (Exception e) {
e.printStackTrace();
} finally {
releaseConnection(conn);
}
return true;
}
下面就此问题的解决办法,做一下小结:
我们可以通过创建单独的OracleCommand来进行指定的插入,即可获得成功,这里仅介绍插入clob类型的数据,blob与此类似,这里就不介绍了,下面介绍两种办法,均已验证:
第一种方法(单条处理):使用组件System.Data.OracleClient的方法来实现,比较简单一些:
string conn = "Data Source=客户端指定连接字符串;User ID=user;Password=mima";
OracleConnection Con = new System.Data.OracleClient.OracleConnection(conn);
Con.Open();
string cmdText = "INSERT INTO GWEXPOINTLIST(id, name, content) VALUES(1, ‘name', :clob)";
OracleCommand cmd = new OracleCommand(cmdText, Con);
OracleParameter op = new OracleParameter("clob", OracleType.Clob);
op.Value = "超过4000字符的超常字符串";
cmd.Parameters.Add(op);
cmd.ExecuteNonQuery();
Con.Close();
第二种方法[b](单条处理):使用组件Oracle.DataAccess的方法实现,可能用法稍微老了一些,但依然有效:[/b]
IDbCommand m_objCmd = new OracleCommand();
m_objCmd.CommandText = "INSERT INTO GWEXPOINTLIST(id, name, content) VALUES(1, ‘name', :clob)";
IDataParameterCollection m_arrParamter = m_objCmd.Parameters;
OracleClob clob = new OracleClob((OracleConnection)m_objConn);
OracleParameter objParam = new OracleParameter(‘clob', OracleDbType.Clob, clob, ParameterDirection.Input);
objParam.Value = "超过4000字符的超常字符串";
m_arrParamter.Insert(0, objParam);
int nRet = m_objCmd.ExecuteNonQuery();
当然,sql server同样也可以通过这样的方法来进行添加字符串,但是添加二进制文件的话,就只能用这种方式来添加了,因为需要读取文件的二进制流内容。
第三种方法(单条处理):比较简单
pstmt.setCharacterStream(4, new StringReader(map.get("TEMPLATE_INFO")), map.get("TEMPLATE_INFO").length());
map.get("TEMPLATE_INFO")就是那个超长的字符串
第四种方法(批处理)org.springframework.jdbc.core.JdbcTemplate:
public static int insert(final JT_po[] sqlArray) throws Exception {
String sql="insert into JT_pojo(id,title,Newstime,Onclick,Titleurl,Newtext,Newstype) values(?,?,?,?,?,?,?)";
try{
// getJdbcTemplate() 获取的是JdbcTemplate
int[] ii =getJdbcTemplate().batchUpdate(sql, new BatchPreparedStatementSetter(){
public void setValues(PreparedStatement ps, int i)
throws SQLException {
JT_po jt= sqlArray[i];
ps.setString(1,jt.getId());
ps.setString(2,jt.getTitle());
ps.setString(3,jt.getNewstime());
ps.setString(4,jt.getOnclick());
ps.setString(5,jt.getTitleurl());
ps.setString(6,jt.getNewstext());
ps.setString(7,jt.getAllcount());
}
@Override
public int getBatchSize() {
return sqlArray.length;
}
});
return ii.length;
}catch (org.springframework.dao.DataAccessException e) {
e.printStackTrace();
}
return 0;
}
第五种方法(批处理)java.sql.PreparedStatement
public boolean insertggpt(String dsname, JT_po[] sqlArray) {
Connection conn = null;
PreparedStatement ps = null;
String sql="insert into JT_pojo(id,title,Newstime,Onclick,Titleurl,Newtext,Newstype) values(?,?,?,?,?,?,?)";
try{
conn = getConnection(dsname);
if (conn!=null && !conn.isClosed()) {
ps = conn.prepareStatement(sql);
//优化插入第一步 设置手动提交
conn.setAutoCommit(false);
for(int i=0; i<sqlArray.length; i++) {
JT_po jt= sqlArray[i];
ps.setString(1,jt.getId());
ps.setString(2,jt.getTitle());
ps.setString(3,jt.getNewstime());
ps.setString(4,jt.getOnclick());
ps.setString(5,jt.getTitleurl());
ps.setString(6,jt.getNewstext());
ps.setString(7,jt.getAllcount());
ps.addBatch();
}
ps.executeBatch();
conn.commit();
ps.clearBatch(); //提交后,Batch清空。
}
} catch (Exception e) {
e.printStackTrace();
} finally {
releaseConnection(conn);
}
return true;
}
相关文章推荐
- Oracle中如何插入超4000字节的CLOB字段的处理方法
- Oracle 插入超4000字节的CLOB字段的处理方法
- 拼组SQL中,Oracle插入超4000字节的CLOB字段的处理方法
- Oracle 插入超4000字节的CLOB字段的处理方法
- Oracle 插入超4000字节的CLOB字段的处理方法
- Oracle 插入超4000字节的CLOB字段的处理方法
- java 将长度很长的字符串(巨大字符串超过4000字节)插入oracle的clob字段时会报错的解决方案
- oracle CLOB类型超过4000个字段sql插入方法
- Oracle CLOB字段处理方法
- ibatis 处理oracle clob大字段方法
- 怎样用JSP处理Oracle中CLOB类型的字段
- C# 结合 oracle处理clob字段文件时出错
- clob大字段jdbc直连(怎么连都可以,这里写的是直连的方法),新增和修改时不乱码的处理
- oracle的blob和clob字段的处理
- 原来oracle的clob字段处理是如此的简单
- Asp.net Oracle Clob 大文本处理方法
- 如何用jsp处理Oracle中CLOB类型的字段
- 在oracle中插入CLOB字段(JDK1.5以后)
- JSTL+EL表达式方法获取Oracle的Clob字段内容 推荐
- Oracle处理Clob字段 转换请求无法实现或不合理