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

JDBC链接数据库,并实现简单的增删改查

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

JDBC链接数据库,并实现简单的增删改查

准备工作:

数据库是:Mysql 8.0

数据库图形化工具是:navicat

java 编译器是:IDEA

框架是:maven

第一步:数据库的初始化

第二步:创建maven工程,导入JDBC的依赖
  
            
                mysql
                mysql-connector-java
                5.0.7
            
            
            
                org.springframework
                spring-jdbc
                5.0.7.RELEASE
            
第三步:编写代码

部分代码截屏:

源代码:

package com.snd.s;

import java.sql.*;

public class text {
    public static void main(String[] args)throws Exception {
        //获取链接对象
        Connection connection = getConnection();
        //增添数据
        zeng(connection);
        //删除数据
        delete(connection);
        //修改表中的数据
        alter(connection);
        //查看表中所有的数据
        viewingADatabase(connection);
    }

    
    public static void viewingADatabase(Connection connection) throws SQLException {
        //获取执行者对象
        Statement statement = connection.createStatement();
        //查询语句
        String sql = "SELECT * FROM user";
        //执行语句,并返回结果
        ResultSet resultSet2 = statement.executeQuery(sql);
        //处理结果
        while (resultSet2.next()){
            System.out.println(resultSet2.getLong("id")+"t"+resultSet2.getString("name"));
        }
        //关闭资源
        resultSet2.close();
        statement.close();
        connection.close();
    }

    
    public static void alter(Connection connection) throws SQLException {
        String sql = "update user set name = '花木兰' where id = 15";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        preparedStatement.executeUpdate();
    }
    
    public static void delete(Connection connection) throws SQLException {
        String sql = "delete from user where id=10";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        preparedStatement.executeUpdate();
    }
    
    public static void zeng(Connection connection) throws SQLException {
        String sql = "INSERT INTO user(id,name)VALUES(15,'snd')";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        preparedStatement.executeUpdate();
    }
    
    public static Connection getConnection() throws SQLException, ClassNotFoundException {
        Class.forName("com.mysql.jdbc.Driver");
        //?useUnicode=true&characterEncoding=utf-8  设置字符集避免出现乱码
        //10.10.196.92   链接数据库的ip地址
        //3306   数据库服务的端口号
        //mybatis_plus  链接数据库的库名
        //root    用户名
        //***********  密码(自己设置的,一定要记好)
        Connection connection = DriverManager.getConnection("jdbc:mysql://10.10.196.92:3306/mybatis_plus?useUnicode=true&characterEncoding=utf-8", "root", "***********");
        return connection;
    }
}

实现JDBC链接数据库,并实现增删改查

测试结果:

 注意:每次运行完后,记得关闭资源,避免资源的浪费;我的代码中,是以查看表中所有的数据的viewingADatabase()方法结尾,所以在viewingADatabase()方法运行完后关闭资源就可以啦,在运行的途中关闭资源会报错。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/862991.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

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

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