/*** 测试与数据库的连接*/
package com.sxt.jdbc;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;public class Demo01 {public static void main(String[] args) throws Exception {//1、加载mysql驱动Class.forName("com.mysql.jdbc.Driver");//加载mysql数据库的Driver类驱动。这个类是由mysql厂商写的驱动程序的提供，非sun官方//2、建立连接。程序与数据库建立连接(是比较耗时的)。Connection是Java官方给的接口，让数据库厂商去实现它。//参数("jdbc:mysql://host:port/database","user","password");那台机器那个端口连接哪一个数据库，用户名，密码Connection coon=DriverManager.getConnection("jdbc:mysql://localhost:3306/testjdbc","root","123456");//3、执行sql语句。execute:[英文]执行  Statement：声明；事务；语句. Statement是Java官方的接口/**Statement容易发生sql注入的危险。因为他可以采用拼接字符串的形式，参数可以从外界传进来，可能有恶意代码* 下面的id采用拼接字符串的形式* String id="5 or 1=1";  这个 or 1=1就是恶意代码，可以把数据库的所有数据删除。* String sqlStr="delete from t_user where id"+id;* 这种方式不推荐* */        /*Statement state=coon.createStatement();String sqlStr="insert into t_user (id,username,pwd,ragTime) values (5,'李贺',980,now())";state.execute(sqlStr);*//**使用PreparedStatement提高安全性,PreparedStatement是Java官方的接口，有数据库厂商提供实现*?是占位符，外界只能传入符合数据库类型的数据，像or 1=1这样的恶意代码不能传入。第1个？代表只能传入一个int型数字*其余同理。防止sql恶意注入，提高安全* */String sql="insert into t_user (id,username,pwd,ragTime) values (?,?,?,now())";//?是占位符PreparedStatement ps=coon.prepareStatement(sql);ps.setObject(1, 6);//1代表第1个占位符,不是从0开始，6是id号. 等价于ps.setInt(1, 6); Object是通用类型ps.setObject(2, "苏轼");//2代表第2个占位符 等价于ps.setString(2, "苏轼");ps.setObject(3, "897");//传入时间也可采用new java.sql.Date(System.currentTimeMillis()),前提是采用占位符//ps.execute();//executeUpdate()：运行insert/update/delete操作，返回更新的行数,是个int的值，表示受到这个sql语句影响的行数String sql2="select *from t_user where id>?";PreparedStatement ps2=coon.prepareStatement(sql2);ps2.setObject(1, 2);//查询id>2的记录 ，Query[英文]查询ResultSet rs=ps2.executeQuery();//executeQuery()：运行select语句，返回ResultSet结果集while (rs.next()) {//1 2 3 4代表列 第l列数int型 第2和3列数String型 第4列是Date型System.out.println(rs.getInt(1)+"  "+rs.getString(2)+"  "+rs.getString(3)+"  "+rs.getDate(4));    }//4、关闭连接 顺序是result ->statement-> connection
        rs.close();ps2.close();ps.close();coon.close();}
}

/*** 练习批处理*/
package com.sxt.jdbc;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;public class Demo02 {public static void main(String[] args) throws Exception {Class.forName("com.mysql.jdbc.Driver");Connection coon=DriverManager.getConnection("jdbc:mysql://localhost:3306/testjdbc","root","123456");coon.setAutoCommit(false);//把事务(执行语句) 设为手动提交就是false
        Statement state=coon.createStatement();for (int i = 10; i < 15; i++) {//Batch:[英文]一批state.addBatch("insert into t_user (id,username,pwd,ragTime) values ("+i+",'李 "+i+" ',888,now())");            }state.executeBatch();coon.commit();}}

/**** 测试事务*/
package com.sxt.jdbc;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.Statement;public class Demo03 {public static void main(String[] args) throws Exception {Class.forName("com.mysql.jdbc.Driver");Connection coon=DriverManager.getConnection("jdbc:mysql://localhost:3306/testjdbc","root","123456");coon.setAutoCommit(false);//默认是true 自动提交,这里是手动提交。通过设置如果ps2语句有错，即使ps1语句没错//数据库也不会改变因为他们是一批事务.他们要么同时成功要么同时失败。
        PreparedStatement ps1=coon.prepareStatement("insert into t_user (id,username,pwd,ragTime) values (?,?,?,now())");ps1.setObject(1, 7);ps1.setObject(2, "韩愈");ps1.setObject(3, "667");        ps1.execute();Thread.sleep(2000);PreparedStatement ps2=coon.prepareStatement("insert into t_user (id,username,pwd,ragTime) values (?,?,?,now())");ps2.setObject(1, 8);ps2.setObject(2, "陆游");ps2.setObject(3, "907");        ps2.execute();coon.commit();}}

/**** 测试时间处理相关的(java.sql.Date 年月日,Time 时分秒,TimeStamp 时间戳 年与日时分秒)*/
package com.sxt.jdbc;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.Timestamp;
import java.util.Random;public class Demo04 {public static void main(String[] args) throws Exception {Class.forName("com.mysql.jdbc.Driver");Connection coon=DriverManager.getConnection("jdbc:mysql://localhost:3306/testjdbc","root","123456");PreparedStatement ps1=coon.prepareStatement("insert into t_user (id,username,pwd,ragTime) values (?,?,?,?)");ps1.setObject(1, 9);ps1.setObject(2, "曹操");ps1.setObject(3, "689");//1、测试java.sql.Datejava.sql.Date date=new java.sql.Date(System.currentTimeMillis());ps1.setObject(4, date);//Date类在添加到数据库中只有年月日是没有时分秒,如果数据库采用时间戳格式则时分秒默认为00:00:00    //ps1.execute();//2、测试java.sql.TimeStamp 时间戳PreparedStatement ps2=coon.prepareStatement("insert into t_user (id,username,pwd,ragTime) values (?,?,?,?)");ps2.setObject(1, 10);ps2.setObject(2, "杜牧");ps2.setObject(3, "459");//若要插入指定日期需要使用Calendar类 或者DateFormat类Timestamp ts =new Timestamp(System.currentTimeMillis());ps2.setObject(4, ts);//ps2.execute();//3、测试插入随机日期for (int i = 15; i <= 20; i++) {PreparedStatement ps3=coon.prepareStatement("insert into t_user (id,username,pwd,ragTime) values (?,?,?,?)");ps3.setObject(1, i);ps3.setObject(2, "杜"+i);ps3.setObject(3, "999");int rand=200000+new Random().nextInt(10000000);//1000万范围的随机数+200000 Timestamp ts2 =new Timestamp(System.currentTimeMillis()-rand);//单位是毫秒ps3.setObject(4, ts2);ps3.execute();}}
}

/**** 查询指定日期的记录*/
package com.sxt.jdbc;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.text.DateFormat;
import java.text.SimpleDateFormat;import javax.xml.stream.events.EndDocument;public class Demo05 {public static long strToDate(String strDate) throws Exception {DateFormat format=new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");        return format.parse(strDate).getTime();//把传进来的字符串改成时间格式然后获取它的时间
    }public static void main(String[] args) throws Exception {Class.forName("com.mysql.jdbc.Driver");Connection coon=DriverManager.getConnection("jdbc:mysql://localhost:3306/testjdbc","root","123456");String sql="select *from t_user where ragTime>? and ragTime<?";PreparedStatement ps=coon.prepareStatement(sql);java.sql.Timestamp start=new java.sql.Timestamp(strToDate("2019-05-10 10:00:00"));java.sql.Timestamp end=new java.sql.Timestamp(strToDate("2019-05-15 10:00:00"));ps.setObject(1, start);//设置第一个占位符，查询ragTime>start的记录 ，Query[英文]查询ps.setObject(2, end);ResultSet rs=ps.executeQuery();//executeQuery()：运行select语句，返回ResultSet结果集while (rs.next()) {//1 2 3 4代表列 第l列数int型 第2和3列数String型 第4列是Date型 也可以写rs.getInt("id")等System.out.println(rs.getInt(1)+"  "+rs.getString(2)+"  "+rs.getString(3)+"  "+rs.getTimestamp(4));    }}}