java,Blob字段操作,将图片或者文件保存到数据库中.zip

package blob字段操作; import java.awt.*; import javax.swing.*; import com.borland.jbcl.layout.XYLayout; import com.borland.jbcl.layout.*; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.image.*; import java.sql.*; import java.io.*; import java.util.*; public class BlobOperFrame extends JFrame { JPanel contentPane; XYLayout xYLayout1 = new XYLayout(); JButton btnUpdate = new JButton(); JTextField jtfSql = new JTextField(); JLabel lblPict = new JLabel(); JButton btnGet = new JButton(); JButton btnLoadPict = new JButton(); Connection connection = null; Statement statement = null; JLabel lblOut = new JLabel(); JTextField jtfEquipName = new JTextField(); JTextField jtfSelect = new JTextField(); public BlobOperFrame() { try { setDefaultCloseOperation(EXIT_ON_CLOSE); jbInit(); initForm(); } catch (Exception exception) { exception.printStackTrace(); } } /** * Component initialization. * * @throws java.lang.Exception */ private void jbInit() throws Exception { contentPane = (JPanel) getContentPane(); contentPane.setLayout(xYLayout1); setSize(new Dimension(400, 300)); setTitle("Blob字段操作"); btnUpdate.setText("Update"); btnUpdate.addActionListener(new BlobOperFrame_jButton1_actionAdapter(this)); jtfSql.setText( "Update fmis04.equ_Equipment set EquipPict = ? where EquipCode = \'111\'"); lblPict.setIcon(null); lblPict.setText("lblIn"); btnGet.setText("Get"); btnGet.addActionListener(new BlobOperFrame_btnGet_actionAdapter(this)); btnLoadPict.setText("LoadPic"); btnLoadPict.addActionListener(new BlobOperFrame_btnLoadPict_actionAdapter(this)); lblOut.setText("lblOut"); jtfEquipName.setText("jtfEquipName"); jtfSelect.setToolTipText(""); jtfSelect.setText( "select * from fmis04.equ_Equipment where EquipCode = \'111\'"); contentPane.add(lblPict, new XYConstraints(32, 93, 133, 115)); contentPane.add(lblOut, new XYConstraints(234, 107, 135, 110)); contentPane.add(jtfEquipName, new XYConstraints(230, 90, 128, 21)); contentPane.add(jtfSql, new XYConstraints(3, 6, 381, 32)); contentPane.add(jtfSelect, new XYConstraints(6, 50, 380, 26)); contentPane.add(btnLoadPict, new XYConstraints(63, 199, 75, 22)); contentPane.add(btnUpdate, new XYConstraints(48, 229, 121, 27)); contentPane.add(btnGet, new XYConstraints(224, 224, 98, 31)); } private void initForm() { try { Class.forName("COM.ibm.db2.jdbc.app.DB2Driver"); String url = "jdbc:db2:EquData"; connection = DriverManager.getConnection(url, "db2admin", "lysdb2"); statement = connection.createStatement(); } catch (SQLException ex) { System.out.println("----------SQL Exception SQL错误---------"); while (ex != null) { System.out.println("Message" + ex.getMessage()); System.out.println("SQLSatate" + ex.getSQLState()); System.out.println("ErrorCode" + ex.getErrorCode()); ex.getNextException(); } } catch (Exception ex) { ex.printStackTrace(); } } public void jButton1_actionPerformed(ActionEvent e) { String strSql = jtfSql.getText(); /* try { PreparedStatement preState = connection.prepareStatement(strSql); File fileBlob = new File("D:\\BmpIcoJpg\\bmp\\Help.bmp"); int iLength = (int)fileBlob.length(); FileInputStream inStr = new FileInputStream(fileBlob); preState.setBinaryStream(1, inStr, iLength); preState.executeUpdate(); } catch (Exception ex) { System.out.println("--准备SQL语句出错------"); ex.printStackTrace(); } */ Vector vecParam = new Vector(); try { File fileBlob = new File("D:\\BmpIcoJpg\\bmp\\Help.bmp"); int iLength = (int)fileBlob.length(); FileInputStream inStr = new FileInputStream(fileBlob); byte bytesParam[] = new byte[iLength]; inStr.read(bytesParam); vecParam.addElement(bytesParam); ExecuteBLOBSqlEx(strSql, vecParam); } catch (Exception ex) { System.out.println("--准备SQL语句出错------"); ex.printStackTrace(); } } public int ExecuteBLOBSql(String strSql, Object objParam) { try { PreparedStatement preState = connection.prepareStatement(strSql); File fileBlob = new File("D:\\BmpIcoJpg\\bmp\\Help.bmp"); int iLength = (int)fileBlob.length(); FileInputStream fileStr = new FileInputStream(fileBlob); byte byteArr[] = new byte[iLength]; fileStr.read(byteArr); System.out.println(String.valueOf(iLength)); FileInputStream strPara = null; byte bytesPara[]; int iLen = 0; Vector vecParam = (Vector)objParam; if (vecParam.size() == 1) { //Blob blob; //blob = (Blob)vecParam.elementAt(0); //strPara = (FileInputStream)vecParam.elementAt(0); //strPara.reset(); //while( strPara.read() >= 0 ) { // iLen = iLen + 1; //} bytesPara = (byte[])vecParam.elementAt(0); //preState.setBinaryStream(1, strPara, iLength); preState.setBytes(1, bytesPara); } preState.executeUpdate(); } catch (Exception ex) { System.out.println("--执行BlobSQL语句出错------"); ex.printStackTrace(); } return 0; } public int ExecuteBLOBSqlEx(String strSql, Object objParam) { try { PreparedStatement preState = connection.prepareStatement(strSql); byte bytesPara[]; Vector vecParam = (Vector)objParam; if (vecParam.size() == 1) { bytesPara = (byte[])vecParam.elementAt(0); preState.setBytes(1, bytesPara); } else if (vecParam.size() > 1) { for (int i = 0; i < vecParam.size(); i ++) { bytesPara = (byte[])vecParam.elementAt(i); preState.setBytes(i + 1, bytesPara); } } preState.executeUpdate(); } catch (Exception ex) { System.out.println("--执行BlobSQL语句出错------"); ex.printStackTrace(); } return 0; } public void btnLoadPict_actionPerformed(ActionEvent e) { //ImageIcon ima = new ImageIcon("D:\\BmpIcoJpg\\bmp\\Help.bmp"); Icon icon = new ImageIcon("D:\\BmpIcoJpg\\bmp\\Help.bmp"); lblPict.setIcon(icon); lblPict.repaint(); } public void btnGet_actionPerformed(ActionEvent e) { String strSql = jtfSelect.getText(); try { statement = connection.createStatement(); ResultSet rs = statement.executeQuery(strSql); if (rs.next()) { Blob blob = rs.getBlob("EquipPict"); byte buffer[] = new byte[ (int) blob.length()]; InputStream in = blob.getBinaryStream(); in.read(buffer); Icon icon = new ImageIcon(buffer); lblOut.setIcon(icon); lblOut.repaint(); jtfEquipName.setText(rs.getString("EquipName")); } } catch (Exception ex) { System.out.println("--获取数据出错------"); ex.printStackTrace(); } } } class BlobOperFrame_btnGet_actionAdapter implements ActionListener { private BlobOperFrame adaptee; BlobOperFrame_btnGet_actionAdapter(BlobOperFrame adaptee) { this.adaptee = adaptee; } public void actionPerformed(ActionEvent e) { adaptee.btnGet_actionPerformed(e); } } class BlobOperFrame_btnLoadPict_actionAdapter implements ActionListener { private BlobOperFrame adaptee; BlobOperFrame_btnLoadPict_actionAdapter(BlobOperFrame adaptee) { this.adaptee = adaptee; } public void actionPerformed(ActionEvent e) { adaptee.btnLoadPict_actionPerformed(e); } } class BlobOperFrame_jButton1_acti