Java连接数据库(增删改查)
转自:
http://www.java265.com/JavaCourse/202205/3573.html
下文笔者将通过示例的方式讲述数据库的基本操作,如下所示
首先需下载jdbc数据库驱动,并引入相应的jar包
也可以从maven仓库中下载jdbc驱动
例:jdbc操作数据库
package com.java265; import java.sql.*; public class con_test { public static void main(String[] args) { // TODO Auto-generated method stub String driver ="com.mysql.jdbc.Driver"; //定义驱动名称 String url="jdbc:mysql://localhost:3306/jdbctest"; //定义要访问的数据库名(jdbctest为数据库名) String user="root"; //数据库用户名 String password="root"; //数据库登录密码 try { Class.forName(driver); //加载驱动 System.out.println("正在连接数据库..."); Connection con = DriverManager.getConnection(url,user,password); //声明Connection对象并获取数据库连接 if(!con.isClosed()) System.out.println("数据库连接成功"+" "); Statement stat=con.createStatement(); //创建数据库操作对象 String sql="select * from user"; //执行的sql语句 ResultSet rs=stat.executeQuery(sql); //执行sql语句并存放结果 while(rs.next()) //遍历结果集 { String name=rs.getString("name"); //数据库name字段信息 int id=rs.getInt("id"); //数据库id字段信息 float age=rs.getFloat("age"); //数据库score字段信息 System.out.println(id+" "+name+" "+age); } /*********************像IO流一样,使用过的资源都需要关闭******************************/ /***********************先打开的后关闭,后打开的先关闭********************************/ rs.close(); stat.close(); con.close(); /*************************************处理异常**************************************/ } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); System.out.println("数据库驱动加载失败"); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); System.out.println("数据库连接失败"); }finally{ System.out.println(" "+"数据库get"); } } }
数据库删除
PreparedStatement psql; //预处理数据 String sql1="delete from user where id=88"; //sql删除语句 psql=con.prepareStatement(sql1); //执行预处理语句 psql.executeUpdate(); //更新数据 psql.close(); //关闭资源
数据库增添
PreparedStatement pre; String sql2="insert into user(name,id,age)"+"values("林丹晨","898",98)"; pre=con.prepareStatement(sql2); pre.executeUpdate(); pre.close();
数据库更新
PreparedStatement prl; String sql3="update user set age = 22 where id=898 "; prl=con.prepareStatement(sql3); prl.executeUpdate(); prl.close();