JDBC连接Mysql数据库

JDBC连接数据库

JDBC（Java DataBase Connectivity,java数据库连接）是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。JDBC提供了一种基准，据此可以构建更高级的工具和接口，使数据库开发人员能够编写数据库应用程序。

执行流程：

1. 连接数据源。
2. 为数据库传递查询和更新指令。
3. 处理数据库响应并返回的结果。

实现步骤：

1首先要加载驱动程序

1
2
3
1Class.forName("com.mysql.jdbc.Driver");

2

3

2与数据库建立连接

1
2
3
4
5
6
1String url = "jdbc:mysql://127.0.0.1:3306/yu";

2String user = "root";

3String password  = "123456";

4Connection con = DriverManager.getConnection(url, user, password);

5

6

3封装sql语句,封装到PreparedStatement的对象中

1
2
3
4
1String sql = "select * from user";(查找表中所有的元素)

2PreparedStatement ps = conn.prepareStatement(sql);

3

4

4执行sql语句并返回结果集，用ResultSet对象保存

1
2
3
4
5
6
7
8
9
10
11
12
1ResultSet rs = ps.executeQuery();

2while(rs.next()) {

3               int id = rs.getInt(1);

4               String name = rs.getString(2);

5               String password = rs.getString(3);

6               Date birthday = rs.getDate(4);

7               String sex = rs.getString(5);

8               int age = rs.getInt(6);

9               System.out.println(id+"***"+name+"***"+password+"***"+birthday+"***"+age);

10            }

11

12

代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
1import java.sql.Connection;

2import java.sql.DriverManager;

3import java.sql.PreparedStatement;

4import java.sql.ResultSet;

5import java.sql.SQLException;

6import java.util.Date;

7public class JDBCTest {

8        public static void main(String[] args) {

9                //定义一个连接

10                Connection conn = null;

11                PreparedStatement ps = null;

12                ResultSet rs = null;

13                try {

14                        //1,加载驱动   （把我们要用一个mysql驱动类加载到程序中）

15                        Class.forName("com.mysql.jdbc.Driver");

16                        //2,获取数据库的连接,并传给Connection对象

17                        String url = "jdbc:mysql://127.0.0.1:3306/orcl";

18                        String user = "root";

19                        String password = "Zyc200802";

20                        conn = DriverManager.getConnection(url, user, password);

21                        //System.out.println(conn);

22                        //3.封装sql语句,封装到PreparedStatement的对象中

23                        String sql = "select * from user";

24                        ps = conn.prepareStatement(sql);

25                        //4.执行sql语句,返回结果集,用ResultSet对象封装

26                        rs = ps.executeQuery();

27                        //5.对封装到ResultSet对象中的数据进行处理

28                        while(rs.next()) {

29                                int id = rs.getInt(1);

30                                String username = rs.getString(2);

31                                String pw = rs.getString(3);

32                                Date birthday = rs.getDate(4);

33                                String sex = rs.getString(5);

34                                int age = rs.getInt(6);

35                                System.out.println(id+"..."+username+"..."+pw+"..."+birthday+"..."+sex+".."+age);

36                        } 

37                } catch (ClassNotFoundException e) {

38                        // TODO Auto-generated catch block

39                        e.printStackTrace();

40                } catch (SQLException e) {

41                        // TODO Auto-generated catch block

42                        e.printStackTrace();

43                } finally {

44                        try {

45                                rs.close();

46                                ps.close();

47                                conn.close();

48                        } catch (SQLException e) {

49                                // TODO Auto-generated catch block

50                                e.printStackTrace();

51                        }

52                }

53        }

54}

55

56