JDBC 实现数据库的增删改查

柔情只为你懂 2022-09-24 14:18 260阅读 0赞

没有 JDBC和ODBC 之前，访问不同数据库需要编写相应的数据库访问程序，ODBC 使得访问链接数据库的接口统一，访问不同数据库的 API 一致。

JDBC 是 Java Database Connector，JDBC API 主要供开发人员使用，JDBC Driver API 主要供底层 数据库 开发人员使用，用于设计与具体数据库的接口。

JDBC 实现的流程

加载驱动 —— 加载数据库驱动，一般是Class.forName方法实现；

打开链接 —— 开启数据库链接，参数包括数据库 URL 、Name 和 pwd；

执行查询 —— 执行数据库查询语句；

处理结果 —— 处理数据库查询结果；

清理环境 —— 清理数据库环境，依次关闭开启的 API；

下面将展示数据库 MySQL 和 Eclipse 下的 数据库对数据的 增删改查代码

create table tbl_user(
    id int(11) unsigned not null auto_increment,
    name varchar(50) not null default '',
    password varchar(50) not null default '',
    email varchar(50) default '',
    primary key (id))
    engine = InnoDB
    default charset = utf8;
    
    create table tbl_address(
    id int(11) unsigned not null auto_increment,
    city varchar(20) default null,
    country varchar(20) default null,
    user_id int(11) unsigned not null,
    primary key(id))
    engine = innodb
    default charset = utf8;
    
    insert into tbl_user(id,name,password,email) values
    (1,'xiaoming','123456','xiaoming@gmail.com'),
    (2,'xiangzhang','123456','xiaozhang@gmail.com');
    
    insert into tbl_address (city,country,user_id) values
    ('beijing','china',1);
    
    insert into tbl_address (city,country,user_id) values
    ('tianjin','china',2);

package jdbc_Pack_003;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.Statement;
    /*
    jdbc 的执行顺序：
    	1.加载驱动
    	2.打开链接
    	3.执行查询
    	4.处理结果
    	5.清理环境
     */
    public class JDBC_Pack_003 {
    	public static void main(String[] args) {
    		String sql = "select * from tbl_user";
    		Connection conn = null;
    		Statement st = null;
    		ResultSet rs = null;
    		try {
    //			Class 和其他类一样继承自 Obj 类，不同的是 它还封装了 被封装到 JVM 之中的类的信息，类的成员变量，
    //			类的成员方法，类的实现接口或者父类 等等 
    //			forName 用来初始化参数指定的类，并创建一个实例化对象
    //			此处的参数 是 jdbc 中的 MySQL 的驱动程序
    			Class.forName("com.mysql.jdbc.Driver");
    //			localhost 是服务器主机，3360 是主机端口，test 是DB的名字
    			conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test","root","1233211234567");
    			st = conn.createStatement();
    			rs = st.executeQuery(sql);
    			while (rs.next()) {
    				System.out.print(rs.getInt("id")+"   ");
    				System.out.print(rs.getString("name")+"   ");
    				System.out.print(rs.getString("email")+"   ");
    				System.out.println();				
    			}
    		} catch (Exception e) {
    			// TODO: handle exception
    			System.out.println(e.getMessage());
    		}finally{
    			try {
    				rs.close();
    				st.close();
    				conn.close();
    			} catch (Exception e) {
    				// TODO: handle exception
    				System.out.println(e.getMessage());
    			}
    		}
    	}
    }

package jdbc_Pack_004;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.Statement;
    
    public class JDBC_Cls_004 {
    	public static Connection getConnection(){
    		Connection connection = null;
    		try{
    			Class.forName("com.mysql.jdbc.Driver");
    			connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/jsp_db","root","1233211234567");
    			}
    		catch(Exception e){
    			e.printStackTrace();
    		}
    		return connection;
    	} 
    	
    	public static void insert(){
    		Connection connection = getConnection();
    		try {
    			String sql = "INSERT INTO tbl_user(name,password,email)VALUES('Tom','123456','tom@gmail.com')";
    			Statement statement = (Statement) connection.createStatement();
    			int count = statement.executeUpdate(sql);
    			System.out.println("用户向表中插入了"+count+"条记录 ！");
    			connection.close();
    		} catch (Exception e) {
    			// TODO: handle exception
    			e.printStackTrace();
    		}
    	}
    	
    	public static void update(){
    		Connection connection = getConnection();
    		try {
    			String sql = "UPDATE tbl_user SET email='tom@hotmail.com' WHERE name='Tom'";
    			Statement statement = (Statement) connection.createStatement();
    			int count = statement.executeUpdate(sql);
    			System.out.println("用户向表中更新了"+count+"条记录 ！");
    			connection.close();
    		} catch (Exception e) {
    			// TODO: handle exception
    			e.printStackTrace();
    		}
    	}
    	
    	public static void delete(){
    		Connection connection = getConnection();
    		try {
    			String sql = "DELETE FROM tbl_user WHERE name='Tom'";
    			Statement statement = (Statement) connection.createStatement();
    			int count = statement.executeUpdate(sql);
    			System.out.println("用户向表中删除了"+count+"条记录 ！");
    			connection.close();
    		} catch (Exception e) {
    			// TODO: handle exception
    			e.printStackTrace();
    		}
    	}
    	
    	public static void main(String []args) {
    //		insert();
    //		update();
    		delete();
    	}
    }