处理大数据对象

1.处理 CLOB 数据：字符，长篇小说

helloWorld.txt文件

数据库，context的字符集为gb2312

import java.io.File; import java.io.FileInputStream; import java.io.InputStream; import java.sql.Clob; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet;import com.cn.zj.JDBC.model.Book; import com.cn.zj.JDBCUtil.DbUtil;public class demo {private static DbUtil dbUtil=new DbUtil();/*** 添加文本数据* @param book* @return* @throws Exception*/private static int addBook(Book book)throws Exception{Connection con=dbUtil.getCon(); // 获取连接String sql="insert into t_book values(null,?,?,?,?,?)";PreparedStatement pstmt=con.prepareStatement(sql);pstmt.setString(1, book.getBookName()); // 给第一个坑设置值pstmt.setFloat(2, book.getPrice()); // 给第二个坑设置值pstmt.setString(3, book.getAuthor()); // 给第三个坑设置值pstmt.setInt(4, book.getBookTypeId()); // 给第四个坑设置值File context=book.getContext(); // 获取文件InputStream inputStream=new FileInputStream(context);pstmt.setAsciiStream(5, inputStream,context.length()); // 给第五个坑设置值，输入流int result=pstmt.executeUpdate();dbUtil.close(pstmt, con);return result;}public static void main(String[] args) throws Exception {File context=new File("C:/helloWorld.txt");Book book=new Book("helloWorld",100,"baa",1,context);//插入数据int result=addBook(book);if(result==1){System.out.println("添加成功！");}else{System.out.println("添加失敗！");}} }

数据类Book.java,重载构造方法

import java.io.File;/*** 图书模型* @author Administrator**/ public class Book { private int id; private String bookName; private float price; private String author; private int bookTypeId; private File context; //使用流 //构造方法 Source+fields public Book(String bookName, float price, String author, int bookTypeId) {super();this.bookName = bookName;this.price = price;this.author = author;this.bookTypeId = bookTypeId; }//更新数据要包括ID，重载构造方法 public Book(int id, String bookName, float price, String author, int bookTypeId) {super();this.id = id;this.bookName = bookName;this.price = price;this.author = author;this.bookTypeId = bookTypeId; }public Book(String bookName, float price, String author, int bookTypeId, File context) {super();this.bookName = bookName;this.price = price;this.author = author;this.bookTypeId = bookTypeId;this.context = context; }public int getId() {return id; }public void setId(int id) {this.id = id; } public String getBookName() {return bookName; } public void setBookName(String bookName) {this.bookName = bookName; } public float getPrice() {return price; } public void setPrice(float price) {this.price = price; } public String getAuthor() {return author; } public void setAuthor(String author) {this.author = author; } public int getBookTypeId() {return bookTypeId; } public void setBookTypeId(int bookTypeId) {this.bookTypeId = bookTypeId; }public File getContext() {return context; }public void setContext(File context) {this.context = context; }@Override public String toString() {return "Book [id=" + id + ", bookName=" + bookName + ", price=" + price + ", author=" + author + ", bookTypeId="+ bookTypeId + "]"; }}

2.处理 BLOG 数据，在 BLOB 中可以存放二进制大数据对象，比如图片，电影，音乐

数据库

import java.io.File; import java.io.FileInputStream; import java.io.InputStream; import java.sql.Clob; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet;import com.cn.zj.JDBC.model.Book; import com.cn.zj.JDBCUtil.DbUtil;public class demo2 {private static DbUtil dbUtil=new DbUtil();/*** 添加图书* @param book* @return* @throws Exception*/private static int addBook(Book book)throws Exception{Connection con=dbUtil.getCon(); // 获取连接String sql="insert into t_book values(null,?,?,?,?,?,?)";PreparedStatement pstmt=con.prepareStatement(sql);pstmt.setString(1, book.getBookName()); // 给第一个坑设置值pstmt.setFloat(2, book.getPrice()); // 给第二个坑设置值pstmt.setString(3, book.getAuthor()); // 给第三个坑设置值pstmt.setInt(4, book.getBookTypeId()); // 给第四个坑设置值File context=book.getContext(); // 获取文件InputStream inputStream=new FileInputStream(context);pstmt.setAsciiStream(5, inputStream,context.length()); // 给第五个坑设置值File pic=book.getPic(); // 获取图片文件InputStream inputStream2=new FileInputStream(pic);pstmt.setBinaryStream(6, inputStream2, pic.length()); // 给第六个坑设置值int result=pstmt.executeUpdate();dbUtil.close(pstmt, con);return result;}public static void main(String[] args)throws Exception {File context=new File("c:/helloWorld.txt");File pic=new File("D:/fl.jpg");Book book=new Book("复仇者联盟", 100, "复仇者联盟", 1,context,pic);int result=addBook(book);if(result==1){System.out.println("添加成功！");}else{System.out.println("添加失败！");}} }

Book.java文件，加入pic的get，set方法，重写构造方法

import java.io.File;/*** 图书模型* @author Administrator**/ public class Book { private int id; private String bookName; private float price; private String author; private int bookTypeId; private File context; //使用流 private File pic; //图片 //构造方法 Source+fields public Book(String bookName, float price, String author, int bookTypeId) {super();this.bookName = bookName;this.price = price;this.author = author;this.bookTypeId = bookTypeId; }//更新数据要包括ID，重载构造方法 public Book(int id, String bookName, float price, String author, int bookTypeId) {super();this.id = id;this.bookName = bookName;this.price = price;this.author = author;this.bookTypeId = bookTypeId; }public Book(String bookName, float price, String author, int bookTypeId, File context) {super();this.bookName = bookName;this.price = price;this.author = author;this.bookTypeId = bookTypeId;this.context = context; }public Book(String bookName, float price, String author, int bookTypeId, File context, File pic) {super();this.bookName = bookName;this.price = price;this.author = author;this.bookTypeId = bookTypeId;this.context = context;this.pic = pic; }public int getId() {return id; }public void setId(int id) {this.id = id; } public String getBookName() {return bookName; } public void setBookName(String bookName) {this.bookName = bookName; } public float getPrice() {return price; } public void setPrice(float price) {this.price = price; } public String getAuthor() {return author; } public void setAuthor(String author) {this.author = author; } public int getBookTypeId() {return bookTypeId; } public void setBookTypeId(int bookTypeId) {this.bookTypeId = bookTypeId; }public File getContext() {return context; }public void setContext(File context) {this.context = context; }public File getPic() {return pic; }public void setPic(File pic) {this.pic = pic; }@Override public String toString() {return "Book [id=" + id + ", bookName=" + bookName + ", price=" + price + ", author=" + author + ", bookTypeId="+ bookTypeId + "]"; }}

=============================================================
工具类DbUtil.java

import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement; /*** 通用方法* @author Administrator**/ public class DbUtil {//驱动名称private static String jdbcName="com.mysql.jdbc.Driver";//mysql数据库地址private static String dbUrl="jdbc:mysql://localhost:3306/db_book?useUnicode=true&characterEncoding=UTF-8";//用户名private static String dbUserName="root";//密码private static String dbPassword="root";//获取数据库连接的方法public Connection getCon() throws Exception{Class.forName(jdbcName); //加载驱动Connection con=DriverManager.getConnection(dbUrl, dbUserName, dbPassword);return con;}//关闭数据库连接public void close(Statement stmt,Connection con)throws Exception{if(stmt!=null){stmt.close();if(con!=null){con.close();}}} }

总结

以上是生活随笔为你收集整理的处理大数据对象的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。