java 实现读取clob

2023-07-13 09:29:04 446

importjava.sql.Connection; importjava.sql.DriverManager; importjava.sql.ResultSet; importjava.sql.ResultSetMetaData; importjava.sql.SQLException; importjava.sql.Statement; importjava.util.ArrayList; importjava.util.HashMap; importjava.util.List; importjava.util.Map; importjava.sql.Clob;

publicList>queryForList(){ List>rowList=newArrayList>(); Stringdriver=""; Stringurl=""; Stringusername=""; Stringpassword=""; Stringsql=""; log.info("查询sql条件："+sql); try{ //加载驱动程序，此处运用隐式注册驱动程序的方法 Class.forName(driver); log.info("加载驱动成功！"); }catch(ClassNotFoundExceptione){ log.error("加载驱动程序，此处运用隐式注册驱动程序的方法出错："+e.getMessage()); e.printStackTrace(); } try{ //创建连接对象 Connectioncon=DriverManager.getConnection(url,username,password); //创建sql执行对象 Statementst=con.createStatement(); //执行sql语句并返回结果集 ResultSetrs=st.executeQuery(sql); //获得结果集结构信息,元数据 ResultSetMetaDatarsmd=rs.getMetaData(); //获得列数 intcolumnCount=rsmd.getColumnCount(); //用于接收每行数据 MaprowData=null; //clob类型 Clobclob=null; //clob转成String StringclobString=""; while(rs.next()){ rowData=newHashMap(); for(inti=1;i<=columnCount;i++){ //判断数据类型是否为Clob if(rs.getObject(i)instanceofClob){//Clob转String clob=(Clob)rs.getObject(i); clobString=clob.getSubString((long)1,(int)clob.length()); rowData.put(rsmd.getColumnName(i),clobString); }else{ rowData.put(rsmd.getColumnName(i),rs.getObject(i)); } } rowList.add(rowData); } //关闭相关的对象 if(rs!=null){ rs.close(); } if(st!=null){ st.close(); } if(con!=null){ con.close(); } }catch(SQLExceptione){ e.printStackTrace(); } returnrowList; }

java 实现读取clob

热门推荐

随机推荐