Oracle 插入超4000字节的CLOB字段的处理方法

淡淡的烟草味﹌ 2022-06-14 08:58 404阅读 0赞

在通过拼组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();

**第二种方法(单条处理)：使用组件Oracle.DataAccess的方法实现，可能用法稍微老了一些，但依然有效：**

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;  
    \}