JDBC基本操作

Love The Way You Lie 2022-05-28 12:18 162阅读 0赞

/** 导包 */
    public class mysqlDemo {
        public static void main (String [] args){
            Connection con = null;
            Statement state = null;
            PreparedStatement prep = null;
            ResultSet rs = null;
            try {
                //加载驱动类
                Class.forName("com.mysql.jdbc.Driver");
                //建立连接
                con=DriverManager.getConnection("jdbc:mysql://localhost:3306/studentdemouseSSL=false","root","12345678099abc"); 
                String sql1 = "insert into  table1   (username,password) vlaues (123,"安东诺夫卡")";             
                state = con.createStatement();
                state.execute(sql1);
                String sql2 = "insert into table1 (username ,password) values (?,?)";
                prep.setObject(1, 499);
                prep.setObject(2, "世界我想去看看");  
                prep = con.prepareStatement(sql);
                prep.execute();                            //运行语句
                System.out.println(prep.executeUpdate());  //返回受影响行数
    
                String sql2 = "select id,name from student ";
                rs = prep.executeQuery(sql2) ;   //返回结果集
                while(rs.next()){
                System.out.println(rs.getInt(1) + "--" + rs.getString(2));
           }
          //批处理，数据量很大时，最好用statement，因为prepareStatement预编译空间有限，会发生异常
          //设为手动提交
          con.setAutoCommit(false);
          //插入两万条数据
          state = con.createStatement();
          for (int i = 0; i < 200; i++) {
          state.addBatch(" insert into table1 (username,password ) values (3,\"你个煞笔\")");
        }
        state.executeBatch();
        con.commit();//提交
        //事物： 一组要么同时成功，要么同时失败的SQL语句 .
        //            开始于连接数据库并执行一条DML语句
        //            结束于执行commit语句或rollback语句
        //时间类型：java.util.Date
        //             子类：java.sql.Date            表示年月日
        //                   java.sql.Time            表示时分秒
        //                   java.sql.Timestamp  表示年月日时分秒
    
    
    
    
    
    
          //CLOB-----Character Large Object--文本大对象,存储大量文本数据(将文件内容与字符串插入/取出数据库)
          //向数据库插入数据
               String sql1 = "insert into test (Myinfo) values (?)";
                  ps = con.prepareStatement(sql1);
                  方式一（文本文件内容）：
                 ps.setClob(1, new FileReader(new File("src/_JDBC/ClobDemo.dat")));
                 方式二（字符串）：   
                 ps.setClob(1, new BufferedReader(new InputStreamReader(new ByteArrayInputStream("abcdef".getBytes())))); 
                  ps.excuteUpdate();          
           //从数据库取数据
                 String sql2 = "select * from test where username = ?";
                 ps = con.prepareStatement(sql2);
                 ps.setObject(1, 123);
                 rs = ps.executeQuery();
                 while(rs.next()) {
                        Clob c = rs.getClob("Myinfo");
                        Reader  r = c.getCharacterStream();
                        int temp = 0;
                        while ((temp = r.read()) != -1) {
                                  System.out.print((char)temp);
                    }
             }
        //BLOB-----Binary Large Object--二进制大对象,存储大量二进制数据(将图片插入/取出数据库)
            // 将图片插入到数据库
                  String sql1 = "insert into test (HeadingImg) values (?) ";  
                  ps = con.prepareStatement(sql1);
                  ps.setBlob(1, new FileInputStream("BLOBDemo.img/地球.jpg")); 
                  ps.execute();
            //将数据库图片以二进制读取出来  
                 String sql2 = "select * from test where MyInfo=?";
                 ps = con.prepareStatement(sql2);
                 ps.setObject(1, "123");
                 rs = ps.executeQuery();
                 while(rs.next()) {
                       Blob b = rs.getBlob("HeadingImg");//注意导java.sql包
                       InputStream  is = b.getBinaryStream();
                       OutputStream  os = new FileOutputStream("f:/a.jpg");        //以下两行为将图片读取到f盘
                       int temp = 0;
                       while((temp = is.read()) != -1 ) {
                                   os.write(temp);                        //将图片写到f盘里
                                  System.out.print((char)temp);  //将图片以二进制打印在控制台
                         }
                 }
            } catch (ClassNotFoundException e) {
               e.printStackTrace();
              } catch (SQLException e) {
               e.printStackTrace();
              }finally{
                  //关闭
                   /** 关闭代码 */
              }
         }
      }