java 连接数据库

Posted 2020-11-10 呐呐呐那

JDBC（Java Data Base Connectivity,java数据库连接）是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。是Java访问数据库的标准规范

 

JDBC是接口，驱动是接口的实现，没有驱动将无法完成数据库连接，从而不能操作数据库！每个数据库厂商都需要提供自己的驱动，用来连接自己公司的数据库，也就是说驱动一般都由数据库生成厂商提供。

连接数据库步骤

 

1 1.注册驱动.
2         告知JVM使用的是哪一个数据库的驱动
3         //DriverManager.registerDriver(new Driver());
4         //把com.mysql.jdbc.driver这个实现类之间扔到内存里
5         //扔到内存之后调用static静态代码块
6         //静态代码块中注册驱动
7         Class.forName("com.mysql.jdbc.Driver");

 

1 2.获得连接.
2         使用JDBC中的类，完成对MySQL数据库的连接 
3         //要连接的数据库名字，写死,编码方式 ?characterEncoding=utf-8
4         String url ="jdbc:mysql://localhost:3306/goods?characterEncoding=utf-8";
5         String user ="root";
6         String password ="1";
7         Connection conn =DriverManager.getConnection(url, user, password);

1 3.获得语句执行平台
2         通过连接对象获取对SQL语句的执行者对象
3         Statement sta =conn.createStatement();

4.执行sql语句
        使用执行者对象，向数据库执行SQL语句
        获取到数据库的执行后的结果  
    //增加语句
    /*    String str ="insert into sort values(‘3‘,‘文具‘,‘钢笔‘)";
        int i =se.executeUpdate(str);
        System.out.println(i);*/
        //修改语句 update 表名 set 要修改的表名   where 条件  
/*        String str ="update sort set sdesc =‘paike‘ where sid =‘1‘";
        int i =se.executeUpdate(str);
        System.out.println(i);*/
        //删除语句
    /*    String str ="delete from sort where sid =‘7‘";
        int i = se.executeUpdate(str);
        System.out.println(i);*/
        //查询语句
        String str ="select * from sort";
        ResultSet re =se.executeQuery(str);
        while(re.next()){
            System.out.println(re.getInt("sid")+re.getString("sname")+re.getString("sdesc"));
        }

6.释放资源.(先开的后关)
        调用一堆close()方法
        rs.close();
        sta.close();
        conn.close();*/

 封装    重点

 1 这里创建一个新的类
 2 package com.orcale.demo;
 3 
 4 import java.sql.Connection;
 5 import java.sql.DriverManager;
 6 import java.sql.ResultSet;
 7 import java.sql.SQLException;
 8 import java.sql.Statement;
 9 
10 public class Demo04 {
11     private static Connection conn =null;      设置成全局变量
12     static{ 
13         try {    
14             Class.forName("com.mysql.jdbc.Driver");   注册程序，然后写传过去参数内容
15             String url ="jdbc:mysql://localhost:3306/aaa";    
16             String user = "root";
17             String password ="1";
18             conn =DriverManager.getConnection(url, user, password);    
19         } catch (ClassNotFoundException | SQLException e) {   抛出异常
20             e.printStackTrace();
21         }
22     }
23         //获取连接对象
24         public static Connection getConnection(){   
25             return conn;
26         }
27         //关闭数据库
28         public static void close(Connection conn,Statement stat,ResultSet re) throws SQLException{
29             if(conn!=null){
30                 conn.close();
31             }
32             if(stat!=null){
33                 conn.close();
34             }
35             if(re!=null){
36                 re.close();
37             }
38         }
39         public static void close(Connection conn,ResultSet re) throws SQLException{
40             if(conn!=null){
41                 conn.close();
42             }
43             if(re!=null){
44                 re.close();
45             }
46         }
47 }

1     Connection conn =Demo04.getConnection();   调用方法获取
2         String sql ="select * from user";        sql语句
3         Statement stat =conn.createStatement();      获取语句执行平台
4         ResultSet re =stat.executeQuery(sql);        调用
5         while(re.next()){
6             System.out.println(re.getString("name")+re.getString("password"));
7         }