messageentity.java

插入文本文件到数据库中

package insertsqltextdemo.entity;
import insertsqltextdemo.Constants.Constant;
import insertsqltextdemo.VO.MesVO;
import java.sql.*;
import java.io.*;
import java.sql.Clob;
import com.microsoft.jdbc.sqlserver.*;
import com.microsoft.jdbc.base.BaseClob;
import com.microsoft.jdbc.base.BaseImplClob;
import com.microsoft.jdbc.base.BaseClobInputStream;
import java.io.BufferedInputStream;
import java.io.StringBufferInputStream;
public class messageEntity {
  private java.sql.PreparedStatement pst;
  private Connection conn;
  StringBufferInputStream in;
  private java.sql.ResultSet rs;
  private byte[] message;
  public messageEntity()
  {
    conn=Constant.getConnection();
  }
  public int addMes(MesVO mesvo)
  {
    int b=0;
    try {
     // in=new java.io.StringBufferInputStream(mesvo.getMessage().toString());
      pst = conn.prepareStatement("insert mes values(?,?)");
      pst.setString(1,mesvo.getMesName().toString());
      //pst.setClob(2,mesvo.getMessage());
      pst.setString(2,mesvo.getMessage().toString());
     // pst.setAsciiStream(2,in,mesvo.getMessage().length());
      b=pst.executeUpdate();
      System.out.println("KAN:"+b+"haha");
    }
    catch (SQLException ex) {
      ex.printStackTrace();
    }
    return b;
  }
  public byte[] search(MesVO svo)
  {
    try {
      pst = conn.prepareStatement("select message from mes where mesName=?");
      pst.setString(1,svo.getMesName().toString());
      rs=pst.executeQuery();
      File f = new File("F:\\angus\\studyCODE\\rehello5.xls");
      while(rs.next())
      {
        //Clob clob=rs.getClob("message");
        //message=rs.getClob("message").toString();
        //System.out.println(rs.getClob("message").getSubString((long)0,(int)rs.getClob("message").length()));
        //java.io.BufferedInputStream in=new BufferedInputStream(rs.getAsciiStream("message"));
        message=rs.getBytes("message");
        try {
          java.io.FileOutputStream fos = new FileOutputStream(f);
          fos.write(message);
        }
        catch (FileNotFoundException ex1) {
        }
        catch (IOException ex1) {
        }
      }
    }
    catch (SQLException ex) {
      ex.printStackTrace();
    }
          return message;
  }
}