• 技术文章 >数据库 >mysql教程

    mysql中怎样插入图片

    coldplay.xixicoldplay.xixi2020-10-13 16:28:19原创76

    mysql中插入图片的方法:首先要在数据库中建表;然后装载JDBC驱动,建立连接;最后创建Statement接口类,来执行SQL语句即可。

    mysql中插入图片的方法:

    1、首先,先要在数据库中建表。我在名为test的数据库下建立了一个叫pic的表。该表包括3列,idpic, caption和img。其中idpic是主键,caption是对图片的表述,img是图像文件本身。建表的SQL语句如下:

    DROP TABLE IF EXISTS `test`.`pic`;
    CREATE TABLE `test`.`pic` (
     `idpic` int(11) NOT NULL auto_increment,
     `caption` varchar(45) NOT NULL default '',
     `img` longblob NOT NULL,
     PRIMARY KEY (`idpic`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

    将上面的语句输入到命令行中(如果安装了Query Brower, 你可以按照参考[1]中的指示来建表,那样会更加方便。),执行,表建立成功。

    2、实现图像存储类

    表完成后,我们就开始写个Java类,来完成向数据库中插入图片的操作。我们知道,Java与数据库连接是通过JDBC driver来实现的。我用的是MySQL网站上提供的MySQL Connector/J,如果你用的是其他类型的driver, 在下面的实现过程中可能会有些许差别。

    2.1、装载JDBC驱动,建立连接

    JDK中提供的DriverManager接口用来管理Java Application 和 JDBC Driver之间的连接。在使用这个接口之前, DriverManager需要知道要连接的JDBC 驱动。最简单的方法就是用Class.forName()来向DriverManager注册实现了java.sql.Driver 的接口类。对MySQL Connector/J来说,这个类的名字叫com.mysql.jdbc.Driver。

    下面这个简单的示例说明了怎样来注册Connector/J Driver。

    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.SQLException;
      
    public class LoadDriver {
      public static void main(String[] args) {
        try {
          // The newInstance() call is a work around for some
          // broken Java implementations
          Class.forName("com.mysql.jdbc.Driver").newInstance();
           
          // Connection con = DriverManager.getConnection(……)
          // ……
        } catch (Exception ex) {
          // handle the error
        }
    }

    向DriverManager注册了驱动后,我们就可以通过调用 DriverManager.getConnection()方法来获得和数据库的连接。其实在上面的例子中就有这条语句,只不过被注释掉了。在后面的实现中会有完整的例子。

    2.2、PreparedStatement

    完成上面的步骤后,我们就可以同过建立的连接创建Statement接口类,来执行一些SQL语句了。在下面的例子,我用的是PreparedStatement,还有CallableStatement,它可以执行一些存储过程和函数,这里不多讲了。

    下面的代码片断是向pic表中插入一条记录。其中(1)处Connection接口的对象con通过调用prepareStatement 方法得到预编译的SQL 语句(precompiled SQL statement);(2)处是为该insert语句的第一个问号赋值,(3)为第二个赋值,(4)为第三个,这步也是最该一提的,用的方法是setBinaryStream(),第一个参数3是指第三个问号,fis是一个二进制文件流,第三个参数是该文件流的长度。

    PreparedStatement ps;
    …
    ps = con.prepareStatement("insert into PIC values (?,?,?)"); // (1)
    ps.setInt(1, id); //(2)
    ps.setString(2, file.getName()); (3)
    ps.setBinaryStream(3, fis, (int)file.length()); (4)
    ps.executeUpdate();
    …

    2.3、完整代码

    上面列出了完整的代码。

    package com.forrest.storepic;
     import java.io.File;
    import java.io.FileInputStream;
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
      
    /**
     * This class describes how to store picture file into MySQL.
     * @author Yanjiang Qian
     * @version 1.0 Jan-02-2006
     */
    public class StorePictures {
       
      private String dbDriver;
      private String dbURL;
      private String dbUser;
      private String dbPassword;
      private Connection con;
      private PreparedStatement ps; 
      
      public StorePictures() {
        dbDriver = "com.mysql.jdbc.Driver";
        dbURL = "jdbc:mysql://localhost:3306/test";
        dbUser = "root";
        dbPassword = "admin";
        initDB();
      }
       
      public StorePictures(String strDriver, String strURL,
          String strUser, String strPwd) {
        dbDriver = strDriver;
        dbURL = strURL;
        dbUser = strUser;
        dbPassword = strPwd;
        initDB();
      }
      
      public void initDB() {
        try {
          // Load Driver
          Class.forName(dbDriver).newInstance();
          // Get connection
          con = DriverManager.getConnection(dbURL,
              dbUser, dbPassword);      
        } catch(ClassNotFoundException e) {
          System.out.println(e.getMessage());
        } catch(SQLException ex) {
          // handle any errors
          System.out.println("SQLException: " + ex.getMessage());
          System.out.println("SQLState: " + ex.getSQLState());
          System.out.println("VendorError: " + ex.getErrorCode());
      
        } catch (Exception e) {
          System.out.println(e.getMessage());
        }
      }
      
      public boolean storeImg(String strFile) throws Exception {
        boolean written = false;
        if (con == null)
          written = false;
        else {
          int id = 0;
          File file = new File(strFile);
          FileInputStream fis = new FileInputStream(file);
           
          try {       
            ps = con.prepareStatement("SELECT MAX(idpic) FROM PIC");
            ResultSet rs = ps.executeQuery();
             
            if(rs != null) {
              while(rs.next()) {
                id = rs.getInt(1)+1;
              }
            } else {    
              return written;
            }
             
            ps = con.prepareStatement("insert "
                + "into PIC values (?,?,?)");
            ps.setInt(1, id);
            ps.setString(2, file.getName());
            ps.setBinaryStream(3, fis, (int) file.length());
            ps.executeUpdate();
             
            written = true;
          } catch (SQLException e) {
            written = false;
            System.out.println("SQLException: "
                + e.getMessage());
            System.out.println("SQLState: "
                + e.getSQLState());
            System.out.println("VendorError: "
                + e.getErrorCode());
            e.printStackTrace();
          } finally {       
            ps.close();
            fis.close();
            // close db con
            con.close();
          }
        }
        return written;
      }
       
      /**
       * Start point of the program
       * @param args CMD line
       */
      public static void main(String[] args) {
        if(args.length != 1) {
          System.err.println("java StorePictures filename");
          System.exit(1);
        }
        boolean flag = false;
        StorePictures sp = new StorePictures();
        try {
          flag = sp.storeImg(args[0]);
        } catch (Exception e) {
          e.printStackTrace();
        }
        if(flag) {
          System.out.println("Picture uploading is successful.");
        } else {
          System.out.println("Picture uploading is failed.");
        }
      }
    }

    更多相关免费学习推荐:mysql教程(视频)

    以上就是mysql中怎样插入图片的详细内容,更多请关注php中文网其它相关文章!

    本文原创发布php中文网,转载请注明出处,感谢您的尊重!
    专题推荐:mysql 插入图片
    上一篇:mysql数据库怎么创建数据表? 下一篇:如何修改mysql中列的默认值
    第13期线上培训班

    相关文章推荐

    • 认识mysql insert into ... select的锁问题• 如何查询mysql中的所有用户• mysql怎么查看字段的备注• mysql如何按月份分组查询• linux下怎么打开mysql数据库

    全部评论我要评论

  • 取消发布评论发送
  • 1/1

    PHP中文网