使用用SQL语句从电脑导入图片到数据库的方法

--创建图片表
CREATE TABLE W_PIC
(
 ID INT, --编号
 WPATH VARCHAR(80), --完整路径
 PIC VARCHAR(80), --图片名称，不带后缀
 img image --图片内容
)
--图片表中插入数据
INSERT INTO W_PIC(ID,WPATH,PIC)
SELECT 1, 'C:\Users\w\Desktop\产品图片\2#加工图34-C专用.jpg','2#加工图34-C专用'
UNION ALL
SELECT 2, 'C:\Users\w\Desktop\产品图片\129.jpg','129'
--创建游标
DECLARE CUR_PIC CURSOR FOR SELECT ID,WPATH,PIC FROM W_PIC;
DECLARE @ID int, @PATH VARCHAR(80), @PIC VARCHAR(80), @STR VARCHAR(100);
OPEN CUR_PIC;
FETCH NEXT FROM CUR_PIC INTO @ID, @PATH, @PIC;
WHILE @@FETCH_STATUS=0
BEGIN
 SET @STR=STR(@ID); 
 --插入图片数据
 EXECUTE ('UPDATE W_PIC SET img=(SELECT * FROM OPENROWSET(BULK N'''+@PATH+''', SINGLE_BLOB) AS Photo) WHERE ID='+@STR);
 FETCH NEXT FROM CUR_PIC INTO @ID, @PATH, @PIC;
END
CLOSE CUR_PIC;
DEALLOCATE CUR_PIC;

package com.an.jdbc.bean;
 import java.io.FileInputStream;
 import java.io.FileOutputStream;
 import java.io.InputStream;
 import java.sql.Connection;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
 import org.junit.Test;
 import com.an.jdbc.utils.JDBCUtils;
 public class TestBlob {
 //向数据库中插入图片
 @Test
 public void test1() throws Exception{
 String sql = "update beauty set photo = ? where id = ?";
 Connection connection = JDBCUtils.getConnection();
 PreparedStatement ps = connection.prepareStatement(sql);
 FileInputStream fis = new FileInputStream("C:\\Users\\Administrator\\Desktop\\1.jpg");
 ps.setBlob(1, fis);
 ps.setInt(2, 2);
 int update = ps.executeUpdate();
 System.out.println(update>0?"success":"failure");
 JDBCUtils.closeConnection(null, ps, connection);
 }
 //从数据库中读取一张图片
 @Test
 public void test2() throws Exception{
 String sql = "select photo from beauty where id=?";
 Connection connection = JDBCUtils.getConnection();
 PreparedStatement ps = connection.prepareStatement(sql);
 ps.setInt(1, 2);
 ResultSet set = ps.executeQuery();
 if(set.next()){
 InputStream inputStream = set.getBinaryStream(1);
 FileOutputStream fos = new FileOutputStream("src\\copy.jpg");
 byte[] b = new byte[1024];
 int len = -1;
 while((len=inputStream.read(b))!=-1){
 fos.write(b, 0, len);
 }
 fos.close();
 inputStream.close();
 }
 JDBCUtils.closeConnection(null, ps, connection);
 }
 }