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

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

2020-05-31 15:07同尘 Sql Server

这篇文章主要介绍了用SQL语句从电脑导入图片到数据库的方法，文中给大家提到了从MySQL数据库读取图片和向数据库插入图片的代码,需要的朋友可以参考下

使用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;

知识点扩展：

从MySQL数据库读取图片和向数据库插入图片

MySQL数据库中有一个数据类型为Blob类型，此类型为二进制文件类型。下面为从MySQL数据库读取图片和向数据库插入图片的代码，一些的数据库连接和JDBC代码就省去了。

				?

									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);

									    }

									  }