package cn.jdbctest; import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.File; import java.io.FileNotFoundException; import java.io.FileReader; import java.io.FileWriter; import java.io.IOException; import java.io.Reader; import java.io.Writer; import java.sql.Clob; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; public class ClobTest { /** * @param args */ Connection conn=null; PreparedStatement pstat=null; ResultSet rs=null; public static String driver="com.jdbc.mysql.Driver"; public static String url="jdbc:mysql://localhost:3306/test"; public static String user="root"; public static String password="root"; static{ try { Class.forName(driver); } catch (ClassNotFoundException e) { e.printStackTrace(); throw new IncompatibleClassChangeError(); } } public void testSql(){ try { conn=DriverManager.getConnection(url, user, password); String sql="select * from usertable"; pstat=conn.prepareStatement(sql); rs=pstat.executeQuery(); while(rs.next()){ Clob clob=rs.getClob(2); Reader reader=clob.getCharacterStream(); File file = new File("text.java"); Writer writer = new BufferedWriter(new FileWriter(file)); char[] buff = new char[1024]; for(int i=0;(i=reader.read(buff))>0;) { writer.write(buff,0,buff.length); } writer.close(); reader.close(); } } catch (SQLException e) { e.printStackTrace(); e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ try { rs.close(); pstat.close(); conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } public void test1(){ try { conn=DriverManager.getConnection(url, user, password); String sql="insert into usertable(id,text) values(?,?)"; pstat=conn.prepareStatement(sql); File file=new File("d:/log.ext"); BufferedReader buffReader=new BufferedReader(new FileReader(file)); pstat.setInt(1, 1); pstat.setClob(2, buffReader); pstat.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); } catch (FileNotFoundException e) { e.printStackTrace(); }finally{ try { pstat.close(); conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }
在mysql中有个TEXT数据类型可以存储大数据,对大数据的处理要用到流的读写操作
相关推荐
大数据流式处理技术大数据流式处理技术大数据流式处理技术大数据流式处理技术
大数据量表的处理方法对新手很有帮助,希望大家踊跃下载
SQL SERVER利用分区对大数据表处理操作手册.pdfSQL SERVER利用分区对大数据表处理操作手册.pdfSQL SERVER利用分区对大数据表处理操作手册.pdfSQL SERVER利用分区对大数据表处理操作手册.pdfSQL SERVER利用分区对...
SQL SERVER利用分区对大数据表处理操作手册.docxSQL SERVER利用分区对大数据表处理操作手册.docxSQL SERVER利用分区对大数据表处理操作手册.docxSQL SERVER利用分区对大数据表处理操作手册.docxSQL SERVER利用分区对...
在MATlAB中对大数据进行处理+MATLAB中处理大数据的两种方法
随着物联网及云计算技术与应用深入,大数据已经是一个无法回避的问题,大数据及其处理技术逐步收到重视,本文较全面对大数据进行认识,对大数据处理相关技术与发展方向进行阐述和分析。
图像处理,大数据分类图像处理,大数据分类
大数据海量数据的处理方法总结,海量数据处理方法的性能比较,大数据面试题集
《深入理解大数据:大数据处理与编程实践》在总结多年来MapReduce并行处理技术课程教学经验和成果的基础上,与业界著名企业Intel公司的大数据技术...这是本书很多实例的源代码 对很多进行大数据学习的朋友们会很有帮助
大数据平台是指通过大数据技术对大量数据进行收集、存储、处理和分析,以获取有价值的信息和知识的一种平台。该平台通常包括数据收集、存储、处理和分析四个主要部分。 了解大数据,首先需要了解大数据的概念,...
随着我国当前社会的不断发展,在大数据时代下计算机信息处理技术得到了蓬勃的发展,计算机信息处理技术被广泛应用于各个领域的日常工作中,对人们的生活和工作带来非常大的影响。为了保证计算机信息处理技术能够在实际...
云计算的出现,对解决生物学大数据有非常重要的作用,对大数据的分配、计算等环节能够快速处理,帮助生物医学解决大数据的处理问题。该文浅谈运用云计算处理生物医学大数据的解决方法进行分析研究,希望能够对其提供可行...
资源名称:sqlserver高级:利用分区对大数据表处理 资源截图: 资源太大,传百度网盘了,链接在附件中,有需要的同学自取。
此外,本书详细介绍了常见的实战问题,比如大数据环境下的配置设置、程序调优等。本书附带的一键安装脚本,更能为初学者提供很大帮助。 【电子版来自互联网,仅供预览及学习交流使用,不可用于商业用途,如有版权问题...
本ppt从认识数据、认识大数据、大数据处理技术三个方面,100页ppt,详细介绍了数据的特性、本质,及如何利用大数据技术处理数据。
关键词:大数据 存储架构 处理技术。高效的大数据存储架构涉及 大数据重复数据删除和编码优化 问题,从这两方面对大数据存储结构进行描述。
数据中心是指对大数据的存储和处理系统,决策支持系统是指对大数据的分析和决策系统。 知识点10:增量建设方式 增量建设方式是指对大数据平台建设项目中的增量式建设方法。增量建设方式是指在基础平台的基础上按照...
ORACLE中对大数据量表的处理方法.pdf
对大数据的透彻理解全文共14页,当前为第1页。对大数据的透彻理解全文共14页,当前为第1页。对大数据的透彻理解 对大数据的透彻理解全文共14页,当前为第1页。 对大数据的透彻理解全文共14页,当前为第1页。 一、 ...