Java连接数据库(增删改查)

转自:
http://www.java265.com/JavaCourse/202205/3573.html
下文笔者将通过示例的方式讲述数据库的基本操作,如下所示

1. 首先需下载jdbc数据库驱动,并引入相应的jar包

复制代码

例:jdbc操作数据库

1. package com.java265;
2. import java.sql.*;
4. public class con_test {
5.                  
6.         public static void main(String[] args) {
7.                                 // TODO Auto-generated method stub
8.                                  String driver ="com.mysql.jdbc.Driver";  //定义驱动名称
9.                                  String url="jdbc:mysql://localhost:3306/jdbctest";   //定义要访问的数据库名(jdbctest为数据库名)
10.                                  String user="root";       //数据库用户名
11.                                  String password="root";  //数据库登录密码                              
12.                                 try {
13.                                         Class.forName(driver);                                 //加载驱动
14.                                         System.out.println("正在连接数据库...");
15.                                     Connection con = DriverManager.getConnection(url,user,password);   //声明Connection对象并获取数据库连接
16.                                         if(!con.isClosed())  System.out.println("数据库连接成功"+"\n");  
17.                                         Statement stat=con.createStatement();             //创建数据库操作对象
18.                                         String sql="select * from user";                   //执行的sql语句
19.                                         ResultSet rs=stat.executeQuery(sql);            //执行sql语句并存放结果
20.                                         while(rs.next())                               //遍历结果集
21.                                         {
22.                                         String name=rs.getString("name");             //数据库name字段信息
23.                                         int id=rs.getInt("id");                       //数据库id字段信息
24.                                         float age=rs.getFloat("age");             //数据库score字段信息
25.                                         System.out.println(id+" "+name+" "+age);
26.                                         }
27. /*********************像IO流一样，使用过的资源都需要关闭******************************/
28. /***********************先打开的后关闭，后打开的先关闭********************************/
29.                                         rs.close();
30.                                         stat.close();                                                       
31.                                         con.close();
32. /*************************************处理异常**************************************/
33.                                 } catch (ClassNotFoundException e) {
34.                                         // TODO Auto-generated catch block
35.                                         e.printStackTrace();
36.                                         System.out.println("数据库驱动加载失败");
37.                                 } catch (SQLException e) {
38.                                         // TODO Auto-generated catch block
39.                                         e.printStackTrace();
40.                                         System.out.println("数据库连接失败");                                       
41.                                 }finally{
42.                             System.out.println("\n"+"数据库get");
43.                         }
44.       }
45. }

复制代码

数据库删除

1. PreparedStatement psql;                               //预处理数据
2. String sql1="delete from user where id=88";        //sql删除语句
3. psql=con.prepareStatement(sql1);                      //执行预处理语句
4. psql.executeUpdate();                                 //更新数据
5. psql.close();                                         //关闭资源

复制代码

数据库增添

1. PreparedStatement pre;
2. String sql2="insert into user(name,id,age)"+"values('林丹晨','898',98)";
3. pre=con.prepareStatement(sql2);
4. pre.executeUpdate();
5. pre.close();

复制代码

数据库更新

1. PreparedStatement prl;
2. String sql3="update user set age = 22 where id=898 ";
3. prl=con.prepareStatement(sql3);
4. prl.executeUpdate();
5. prl.close();

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！