public static void main(String[] args)
throws Exception {
2 //1.注册驱动
3 Class.forName("com.mysql.jdbc.Driver"
);
4 //2.获取数据库连接
5 String url = "jdbc:mysql://localhost:3306/mybase4"
;
6 String user = "root"
;
7 String password = "root"
;
8 Connection conn =
DriverManager.getConnection(url, user, password);
9 //3.获取执行者对象
10 Statement stat =
conn.createStatement();
11 //调用更新数据的方法
12 //update(stat);
13 //调用删除数据的方法
14 //delete(stat);
15 //调用增加数据的方法
16 //insert(stat);
17 //调用查询数据的方法
18 select(stat);
19 //6.释放资源
20 stat.close();
21 conn.close();
22 }
23
24 /*
25 * 使用JDBC技术,查询数据库中表的数据
26 */
27 private static void select(Statement stat)
throws Exception {
28 //拼接sql语句
29 String sql = "SELECT * FROM category"
;
30 /*
31 * 4.执行sql语句
32 * 使用Statement中的方法
33 * ResultSet executeQuery(String sql) 执行给定的 SQL 语句，该语句返回单个 ResultSet 对象。
34 * 返回值ResultSet标准接口的实现类对象,实现类对象由mysql驱动提供,可以使用ResultSet接口接收
35 */
36 ResultSet rs =
stat.executeQuery(sql);
37 System.out.println(rs);
//com.mysql.jdbc.JDBC4ResultSet@1acb189
38 /*
39 * 5.处理结果
40 * ResultSet中有一个方法
41 * boolean next() 将光标从当前位置向前移一行。
42 * 如果新的当前行有效，则返回 true；如果不存在下一行，则返回 false
43 * 如果有结果集返回true,若果没有结果集返回false
44 * 相当于迭代器中的hasNext方法
45 */
46 while(rs.next()){
47 /*
48 * next返回true,有结果集
49 * 取出结果集
50 * 使用ResultSet中的方法getXXX(参数);
51 * 参数:
52 * int columnIndex:列所在的索引,从1开始
53 * String columnLabel:列名
54 * 注意:
55 * 如果使用getInt,getDouble指定数据类型的方法,返回值就是对应的数据类型
56 * 如果使用getObject方法返回值是object类型(只是打印可用)
57 * 如果使用getString方法返回值是String类型
58 */
59 /*int i1 = rs.getInt(1);
60 String s2 = rs.getString(2);
61 System.out.println(i1+"\t"+s2);*/
62
63 //System.out.println(rs.getObject(1)+"\t"+rs.getObject(2));
64 System.out.println(rs.getObject("cid")+"\t"+rs.getObject("cname"
));
65 //5.释放资源
66 rs.close();
67 }
68 }
69
70 /*
71 * 使用JDBC技术,对数据库中的表数据进行增加
72 */
73 private static void insert(Statement stat)
throws SQLException {
74 //拼接sql语句
75 String sql = "INSERT INTO category(cname) VALUES(‘玩具‘)"
;
76 //4.执行sql语句
77 int row =
stat.executeUpdate(sql);
78 //5.处理结果
79 if(row>0
){
80 System.out.println("增加数据成功!"
);
81 }
else{
82 System.out.println("增加数据失败!"
);
83 }
84
85 }
86
87 /*
88 * 使用JDBC技术,对数据库中的表数据进行删除
89 */
90 private static void delete(Statement stat)
throws Exception {
91 //拼接sql语句
92 String sql = "DELETE FROM category WHERE cid=5"
;
93 //4.执行sql语句
94 int row =
stat.executeUpdate(sql);
95 //5.处理结果
96 if(row>0
){
97 System.out.println("删除数据成功!"
);
98 }
else{
99 System.out.println("删除数据失败!"
);
100 }
101 }
102
103 /*
104 * 使用JDBC技术,对数据库中的表数据进行更新
105 */
106 private static void update(Statement stat)
throws Exception {
107 //拼接sql语句
108 String sql = "UPDATE category SET cname=‘鞋帽‘ WHERE cid=6"
;
109 //4.执行sql语句
110 int row =
stat.executeUpdate(sql);
111 //5.处理结果
112 if(row>0
){
113 System.out.println("更新数据成功!"
);
114 }
else{
115 System.out.println("更新数据失败!"
);
116 }
117 }
1 JDBC工具类
2 “获得数据库连接”操作，将在以后的增删改查所有功能中都存在，可以封装工具类JDBCUtils。提供获取连接对象的方法，从而达到代码的重复利用。
3 代码演示:
4 public class JDBCUtils {
5
6 //私有构造方法,防止外界创建对象调用方法
7 private JDBCUtils() {
8 }
9
10 //定义Connectionn变量
11 private static Connection conn;
12
13 //保证代码只执行一次,可以放入静态代码块中
14 static{
15 try {
16 //注册驱动
17 Class.forName("com.mysql.jdbc.Driver");
18 //获取连接
19 String url="jdbc:mysql://127.0.0.1:3306/mybase4";
20 String user="root";
21 String password = "root";
22 conn = DriverManager.getConnection(url, user, password);
23 } catch (Exception e) {
24 //注意,如果连接数据库失败,停止程序
25 throw new RuntimeException(e+"连接数据库失败");
26 }
27 }
28
29 //创建一个静态方法,获取数据库连接对象,并返回
30 public static Connection getConnection(){
31 return conn;
32 }
33
34 /*
35 * 创建一个静态方法,对资源进行释放
36 * ResultSet rs
37 * Statement stat
38 * Connection conn
39 */
40 public static void close(ResultSet rs,Statement stat,Connection conn){
41 try {
42 if(rs!=null){
43 rs.close();
44 }
45 } catch (SQLException e) {
46 e.printStackTrace();
47 }
48 try {
49 if(stat!=null){
50 stat.close();
51 }
52 } catch (SQLException e) {
53 e.printStackTrace();
54 }
55 try {
56 if(conn!=null){
57 conn.close();
58 }
59 } catch (SQLException e) {
60 e.printStackTrace();
61 }
62 }
63 }
sql注入问题
SQL注入：用户输入的内容作为了SQL语句语法的一部分，改变了原有SQL真正的意义。
假设有登录案例SQL语句如下:
SELECT * FROM 用户表 WHERE NAME = 用户输入的用户名 AND PASSWORD = 用户输的密码;
此时，当用户输入正确的账号与密码后，查询到了信息则让用户登录。但是当用户输入的账号为XXX 密码为：XXX’ OR ‘a’=’a时，则真正执行的代码变为：
SELECT * FROM 用户表 WHERE NAME = ‘XXX’ AND PASSWORD =’ XXX’ OR ’a’=’a’;
此时，上述查询语句时永远可以查询出结果的。那么用户就直接登录成功了，显然我们不希望看到这样的结果，这便是SQL注入问题。
为此，我们使用PreparedStatement来解决对应的问题。
preparedStatement：预编译对象，是Statement对象的子类。
特点：
性能高
会把sql语句先编译
能过滤掉用户输入的关键字。
PreparedStatement预处理对象，处理的每条sql语句中所有的实际参数，都必须使用占位符?替换。
String sql = "select * from user where username = ? and password = ?";
PreparedStatement使用，需要通过以下3步骤完成：
1.PreparedStatement预处理对象代码：
获得预处理对象，需要提供已经使用占位符处理后的SQL语句
PreparedStatement psmt = conn.prepareStatement(sql)
2.设置实际参数
void setXxx(int index, Xxx xx) 将指定参数设置指定类型的值
参数1：index 实际参数序列号，从1开始。
参数2：xxx 实际参数值，xxx表示具体的类型。
例如：
setString(2, "1234") 把SQL语句中第2个位置的占位符?替换成实际参数 "1234"
3.执行SQL语句:
int executeUpdate(); --执行insert update delete语句.
ResultSet executeQuery(); --执行select语句.
boolean execute(); --执行select返回true 执行其他的语句返回false.
原生JDBC
标签：连接数 ase style io流 网址 整数 class new 关闭
