栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

JDBC基础知识点,JDBC连接数据库

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

JDBC基础知识点,JDBC连接数据库

JDCBC:(Java Databases Connection)java数据库连接。
首先从两方面思考:Java是面向对象语言,SQL面向结构化查询语言,要有MySQL和Java基础,按照我自己的理解:
mysql中的每一张表格对应的就是Java中自定义的类,类中的每一个属性 对应的表中的每一列的列名。


JDBC连接步骤:
	1.引入j相应的mysql的jar包:这里引入的是8.0版本的mysql的jar包
	2、加载驱动:Class.forName("com.mysql.cj.jdbc.Driver");  每个版本的mysql加载驱动是不一样的
	3、获取连接对象:Connection connection = DriverManager.getConnection(url,user,password);
	4、获取执行sql语句的对象:
		[Statement statement = connection.createStatement();这个会有sql注入的错误,注:尽量 不用] 下面代码用PreparedStatement这个类以及占位符【?】
	5、执行sql 语句:
	int row=statement.executeUpdate(sql) 或着
	ResultSet resultSet=statement.executeQuery(sql)
	6、关闭资源
		使用close();

结构:

导入的包:
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

在dao层中定义一个工具类UserDao,实现对数据库连接的增删改查:

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

public class UserDao {
    public Connection connection;
    public PreparedStatement ps;
    public ResultSet resultSet;
    //查询所有
    public List findAll(){
        List list=new ArrayList<>();
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/world?serverTimezone=Asia/Shanghai", "root", "123456");
            String sql = "select * from tb_user";  //tb_user是表格的名字  有四列 四个属性
            ps = connection.prepareStatement(sql);
            resultSet = ps.executeQuery();
            while (resultSet.next()) {
                User user = new User();
                //为java对象得属性赋值  
                user.setUid(resultSet.getInt("uid"));
                user.setUname(resultSet.getString("uname"));
                user.setPassword(resultSet.getString("password"));
                user.setSex(resultSet.getString("sex"));
                list.add(user);
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            //TODO 关闭资源  
        }
        return list;
    }


    //根据id查询 1
    public User findById(Integer id){
        User user=null;//声明对象
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/world?serverTimezone=Asia/Shanghai", "root", "root");
            String sql = "select * from tb_user where uid=?";
            ps = connection.prepareStatement(sql);
            ps.setObject(1, id);
            resultSet = ps.executeQuery();
            while (resultSet.next()) {
                user = new User();
                //为java对象得属性赋值
                user.setUid(resultSet.getInt("uid"));
                user.setUname(resultSet.getString("uname"));
                user.setPassword(resultSet.getString("password"));
                user.setSex(resultSet.getString("sex"));
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            // TODO 关闭资源
        }
        return user;

    }
    //删除 --- id删除
    public int deleteById(int id){
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/world?serverTimezone=Asia/Shanghai", "root", "root");
            String sql = "delete from tb_user where uid=?";
            ps = connection.prepareStatement(sql);
            ps.setObject(1, id);
            int i = ps.executeUpdate();
            return i;
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            // TODO 删除
        }
        return 0;
    }

    //修改
    public int update(User user){
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/world?serverTimezone=Asia/Shanghai", "root", "root");
            String sql = "update tb_user set uname=?,sex=?,password=? where uid=?";
            ps = connection.prepareStatement(sql);
            ps.setObject(1, user.getUname());
            ps.setObject(2, user.getSex());
            ps.setObject(3, user.getPassword());
            ps.setObject(4, user.getUid());
            int i = ps.executeUpdate();
            return i;
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            // TODO 删除
        }
        return 0;
    }
    //增加
    public int insert(User user){
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/world?serverTimezone=Asia/Shanghai", "root", "root");
            String sql = "insert into tb_user(uid,uname,password,sex) values(null,?,?,?)";
            ps = connection.prepareStatement(sql);
            ps.setObject(1, user.getUname());
            ps.setObject(2, user.getPassword());
            ps.setObject(3, user.getSex());
            int i = ps.executeUpdate();
            return i;
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            // TODO 删除
        }
        return 0;
    }
}

entity:里面定义的一些自定义的类 user


public class User {
    private Integer uid;
    private String uname;
    private String sex;
    private String password;
    public Integer getUid() {
        return uid;
    }
    public void setUid(Integer uid) {
        this.uid = uid;
    }
    public String getUname() {
        return uname;
    }
    public void setUname(String uname) {
        this.uname = uname;
    }

    public String getSex() {
        return sex;
    }

    public void setSex(String sex) {
        this.sex = sex;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

}

测试类

package com.ykq.test;

import com.ykq.dao.UserDao;
import com.ykq.entity.User;

import java.util.List;

public class Test {
    //main理解为浏览器
    public static void main(String[] args) {
        UserDao userDao=new UserDao();
//        User user2=new User();
//        user2.setPassword("110");
//        user2.setSex("男");
//        user2.setUname("迪迦");
//        int row=userDao.insert(user2);
        User user2=new User();
        user2.setPassword("110");
        user2.setSex("男");
        user2.setUname("银河");
        user2.setUid(10);
        int row = userDao.update(user2);
        System.out.println("影响的行数:"+row);
//        int row = userDao.deleteById(3);
//        System.out.println("影响的行数:"+row);
//
        List list = userDao.findAll();
        for(int i=0;i
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/343024.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号