IDEA项目实践——创建Java项目以及创建Maven项目案例、使用数据库连接池创建项目简介

news2024/11/25 6:51:12

系列文章目录

IDEA上面书写wordcount的Scala文件具体操作

IDEA创建项目的操作步骤以及在虚拟机里面创建Scala的项目简单介绍

目录

系列文章目录

前言

一 准备工作

1.1 安装Maven

1.1.1 Maven安装配置步骤

1.1.2 解压相关的软件包

1.1.3 Maven 配置环境变量

1.1.4 配置Maven的私服

1.2 创建一个本地的MySQL数据库和数据表

二 创建Java项目

2.1 方式一 数据库连接池druid

2.1.1 MySQL-connector-java资源分享链接

2.1.2 druid资源链接

2.2 创建Java项目步骤如下

2.2.1 创建项目目录

2.2.2  创建一个新的Java类

2.2.3 导入jar包 

 2.2.4 将jar包加载到library

 2.2.5 编写Java代码

版本一 

版本二

2.3 方式二 配置文件的形式加载

2.3.1 在src目录之下创建配置文件

2.3.2 在配置文件当中添加如下的信息

2.3.3 创建一个demo2的Java文件

 2.3.4 编辑Java代码

三 在IDEA上创建Maven项目来实现上述的功能

3.1 创建项目

 3.2 创建一个Java类

 3.3 编辑Java代码和配置文件

3.4 Java代码模块讲解

3.4.1 Java Scanner 类

3.4.2 系统添加数据模块方法

3.4.3  编辑MySQL与druid依赖

3.4.4 编辑插入数据方法

3.4.5 编辑查询代码

3.4.6  完整的优化后的代码

思考——如何优化上述的Java代码? 

总结


前言

本文主要介绍IDEA项目实践,创建Java项目以及创建Maven项目案例、使用数据库连接池创建项目简介

一 准备工作

1.1 安装Maven

Maven资源分享包

链接:https://pan.baidu.com/s/1D3SHLKTMTTUDYLv45EXgeg?pwd=kmdf 
提取码:kmdf

1.1.1 Maven安装配置步骤

1. 解压 apache-maven-3.6.1.rar 既安装完成
2. 配置环境变量 MAVEN_HOME 为安装 路径,在 Path 添加 %MAVEN_HOME%/bin 目录
3. 配置本地仓库:修改 conf /settings.xml 中的 < localRepository > 为一个指定目录
4. 配置阿里云私服:修改 conf /settings.xml 中的 <mirrors> 标签,为其添加如下子标签

1.1.2 解压相关的软件包

解压你的Maven包,放在你的文件夹里面,配置相关的本地仓库文件

1.1.3 Maven 配置环境变量

 打开Windows1的高级设置,配置相关的环境变量

第一处

MAVEN_HOME

D:\apache-maven-3.9.3

第二处 

 Path

%MAVEN_HOME%/bin

1.1.4 配置Maven的私服

 需要添加的内容如下:

<mirror>  
<id>alimaven</id>  
<name>aliyun maven</name>  
<url>http://maven.aliyun.com/nexus/content/groups/public/</url>
<mirrorOf>central</mirrorOf>          
</mirror>

创建一个本地仓库文件夹【myRepository】你的仓库创建在你安装了Maven的地方。

在notepad++查找本地的【localRepository

没有notepad++也可以使用记事本编辑,只要将内容修改完,并且保存完成即可。

 在setting文件夹里面加入本地仓库位置

<localRepository>D:\apache-maven-3.9.3\myRepository</localRepository>

 查找mirrors位置,修改为阿里的私服。

 添加完成之后记得保存~

编辑完成之后退出。本地仓库就配置完成了。

1.2 创建一个本地的MySQL数据库和数据表

在此之前,需要配置本地MySQL服务的连接如下:

 MySQL以及MySQL workbench的安装与配置【超详细安装教程】

创建数据库和数据表的SQL语句 

// 创建名为 test 的数据库
CREATE DATABASE test;
// 使用 test 数据库
USE test;
// 创建名为 websites 的表
CREATE TABLE `websites` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` char(20) NOT NULL DEFAULT '' COMMENT '站点名称',
  `url` varchar(255) NOT NULL DEFAULT '',
  `alexa` int(11) NOT NULL DEFAULT '0' COMMENT 'Alexa 排名',
  `country` char(10) NOT NULL DEFAULT '' COMMENT '国家',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=10 DEFAULT CHARSET=utf8;
// 在 websites 中插入数据
INSERT INTO `websites` VALUES ('1', 'Google', 'https://www.google.cm/', '2', 'USA'), 
('2', '淘宝', 'https://www.taobao.com/', '13', 'CN'), 
('3', '菜鸟教程', 'http://www.runoob.com', '5892', 'CN'), 
('4', '微博', 'http://weibo.com/', '20', 'CN'), 
('5', 'Facebook', 'https://www.facebook.com/', '3', 'USA'),
('6', 'JueJin', 'https://www.juejin.cn/', '2213', 'CN');

创建之后的数据库如下图所示的界面: 

二 创建Java项目

2.1 方式一 数据库连接池druid

创建步骤如下:

1. 导入jar包(mysql-connection-java.jar,druid.jar),同时加入到类加载路径中
2. 直接创建连接池对象:new对象 DruidDataSource
3. 然后设置属性。
   1. setDriverClassName()
   2. setUrl()
   3. setUsername()
   4. setPassword()
   5. setInitialSize()  //初始连接数
   6. setMaxSize()   //最大连接数
   7. setMaxWait()   //最大等待时间
4. 通过连接池对象,获取数据库连接

方式一的缺点:将MySQL的URL和用户以及密码是写死的,当你要修改的时候不好修改

2.1.1 MySQL-connector-java资源分享链接

MySQL-connector-java-8.0.31版本百度网盘连接

链接:https://pan.baidu.com/s/1A2NtVswiJjvxFB68GZ77Vw?pwd=wcmo 
提取码:wcmo

MySQL-connector-java-5.1.49版本百度网盘连接

链接:https://pan.baidu.com/s/1FPL23h6Ca7_Y0N_HYZSm0Q?pwd=6kwi 
提取码:6kwi

2.1.2 druid资源链接

druid-1.1.12版本

链接:https://pan.baidu.com/s/13Bwl-R3gN0fU5qHAGFHzwA?pwd=gu9g 
提取码:gu9g

2.2 创建Java项目步骤如下

2.2.1 创建项目目录

选择创建Java文件

 继续下一步

 创建你的问价存储位置,此处建议专门写一个存放IDEA项目的文件夹。

2.2.2  创建一个新的Java类

在src文件里面创建一个新的Java类

名字为: com.ambow.druid.DruidDemo

解释——前三个为包名称,后面为类名称。

2.2.3 导入jar包 

在项目里面新建一个文件夹导入前面的两个jar包【MySQL-connector-java-8.0.31和druid-1.1.12

】,需要自己创建一个libs文件夹存放这两个jar包。

 此处记得选择自己的MySQL对应的Java包,下载之后,将两个jar包复制,将其粘贴在libs文件夹里面即可。

 此处点击ok即可。

同上

 2.2.4 将jar包加载到library

在两个jar包上面,鼠标右键,选择as a library加载

 点击OK即可

 2.2.5 编写Java代码

版本一 

package com.ambow.druid;
import java.sql.*;
//方式一: druid的数据库连接池
public class DruidDemo {
    // MySQL 8.0 以下版本 - JDBC 驱动名及数据库 URL
//    static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
//    static final String DB_URL = "jdbc:mysql://localhost:3306/test";

    // MySQL 8.0 以上版本 - JDBC 驱动名及数据库 URL
    static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
    static final String DB_URL = "jdbc:mysql://localhost:3306/test?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC";


    // 数据库的用户名与密码,需要根据自己的设置
    static final String USER = "root";
    static final String PASS = "root";

    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        try {
            // 注册 JDBC 驱动
            Class.forName(JDBC_DRIVER);

            // 打开链接
            System.out.println("连接数据库...");
            conn = DriverManager.getConnection(DB_URL, USER, PASS);

            // 执行查询
            System.out.println(" 实例化Statement对象...");
            stmt = conn.createStatement();
            String sql;
            sql = "SELECT id, name, url FROM websites";
            ResultSet rs = stmt.executeQuery(sql);

            // 展开结果集数据库
            while (rs.next()) {
                // 通过字段检索
                int id = rs.getInt("id");
                String name = rs.getString("name");
                String url = rs.getString("url");

                // 输出数据
                System.out.print("ID: " + id);
                System.out.print(", 站点名称: " + name);
                System.out.print(", 站点 URL: " + url);
                System.out.print("\n");
            }
            // 完成后关闭
            rs.close();
            stmt.close();
            conn.close();
        } catch (SQLException se) {
            // 处理 JDBC 错误
            se.printStackTrace();
        } catch (Exception e) {
            // 处理 Class.forName 错误
            e.printStackTrace();
        } finally {
            // 关闭资源
            try {
                if (stmt != null) stmt.close();
            } catch (SQLException se2) {
            }// 什么都不做
            try {
                if (conn != null) conn.close();
            } catch (SQLException se) {
                se.printStackTrace();
            }
        }
        System.out.println("Goodbye!");
    }
}

运行结果如下:

版本二

代码演示

package com.ambow.druid;

import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.pool.DruidPooledConnection;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
/*
    方式一: 直接创建DruidDataSource ,然后设置属性
 */
public class DruidDemo {
    public static void main(String[] args) throws SQLException {
        DruidDataSource dds = new DruidDataSource();
        dds.setDriverClassName("com.mysql.cj.jdbc.Driver");
        dds.setUrl("jdbc:mysql://localhost:3306/test?serverTimezone=UTC");
        dds.setUsername("root");
        dds.setPassword("root");

        dds.setInitialSize(5);//初识连接数
        dds.setMaxActive(10);//最大连接数
        dds.setMaxWait(3000);//最大等待时间

        //获取连接
        DruidPooledConnection connection = dds.getConnection();
        System.out.println(connection);

        //获取执行语句对象
        String sql = "select * from websites";
        PreparedStatement pstmt = connection.prepareStatement(sql);
        //获取结果集
        ResultSet rs = pstmt.executeQuery();
        while (rs.next()){
           System.out.println(rs.getInt(1) + "-" + rs.getString(2) + "-" +          
                 rs.getString(3) + "-" +  rs.getInt(4) + "-" +  rs.getString(5));
        }
        /*
            jdbc连接的四个参数:
                driver
                url
                username
                password
         */
    }
}

 运行结果:

2.3 方式二 配置文件的形式加载

  •  导入jar包 mysql-connection-java.jar、druid-1.1.12.jar
  •  定义配置文件
  •  加载配置文件
  •  获取数据库连接池对象
  •  获取连接

此处的代码实现,首先也需要先将druid的jar包放到项目下的lib下并添加为库文件,与前面一样的形式创建。

2.3.1 在src目录之下创建配置文件

文件名称为: druid.properties

PS:Java里面的配置文件为properties类型

2.3.2 在配置文件当中添加如下的信息

将用户以及密码哪些信息写入配置文件 

此处为8.0以上版本的书写方法

driverClassName=com.mysql.cj.jdbc.Driver
url=jdbc:mysql:///test?serverTimezone=UTC
username=root
password=root
# 初始化连接数量
initialSize=5
# 最大连接数
maxActive=10
# 最大等待时间
maxWait=3000

以下为5.1 版本的写法【举例如下】

driverClassName=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://182.168.1.1/test
username=root
password=root
# ???????
initialSize=5
# ?????
maxActive=10
# ??????
maxWait=3000


//前面的是IP地址以及数据库的名称

2.3.3 创建一个demo2的Java文件

 

 2.3.4 编辑Java代码

此处只是一个获取连接的代码 

package com.ambow.druid;

import com.alibaba.druid.pool.DruidDataSourceFactory;
import javax.sql.DataSource;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.util.Properties;

/*
    方式二:提取配置文件(把连接数据库的参数,抽取出来)
 */
public class DruidDemo2 {
    public static void main(String[] args) throws Exception {
        //获取当前项目的根目录
        System.out.println(System.getProperty("user.dir"));
        // 加载配置文件
        Properties prop = new Properties();
        //FileInputStream is = new FileInputStream("src/druid.properties");
        InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("druid.properties");
        prop.load(is);
        // 获取数据库连接池对象
        DataSource ds = DruidDataSourceFactory.createDataSource(prop);
        // 获取连接
        Connection connection = ds.getConnection();
        System.out.println(connection);
    }
}

运行结果:

 注意:

System.getProperty("user.dir"),在web项目,返回值就不是项目的根目录了,而是tomcat的bin目录。

三 在IDEA上创建Maven项目来实现上述的功能

3.1 创建项目

在file里面选择创建新的项目,选择Maven项目

 填写项目的名称,以及公司名称

 点击finsh即可。

此处补全一个资源文件夹

 3.2 创建一个Java类

 3.3 编辑Java代码和配置文件

编辑配置文件的方法与2.3.2 一样,此处不再赘述。 

在刚才的类里面编辑Java代码

package com.ambow.druid;

import java.sql.*;
import java.util.Scanner;


public class App {
    static final String JDBC_DRIVER="com.mysql.cj.jdbc.Driver";
    static final String DB_URL="jdbc:mysql://localhost:3306/test";
    static final String USER = "root";
    static final String PASS ="root";
    static Scanner sc =new Scanner(System.in);//成为类成员前面加入static修饰
    public static void main(String[] args) throws SQLException {
//        DruidDataSource dds = new DruidDataSource();
//        dds.setDriverClassName("com.mysql.jdbc.Driver");
//        dds.setUrl("jdbc:mysql://192.168.127.100:3306/db2");
//        dds.setUsername("root");
//        dds.setPassword("Admin2023!");
//        dds.setInitialSize(5);
//        dds.setMaxActive(10);
//        dds.setMaxWait(3000);
//        DruidPooledConnection connection = dds.getConnection();
//        System.out.println(connection);
        //加入循环
        while (true) {
            System.out.println("***********************************");
            System.out.println("*********** 站点管理系统  ***********");
            System.out.println("*********** 1.新增站点   ***********");
            System.out.println("*********** 2.修改站点   ***********");
            System.out.println("*********** 3.删除站点   ***********");
            System.out.println("*********** 4.查询站点   ***********");
            System.out.println("*********** 0.退出系统   ***********");
            System.out.println("**********************************");
            System.out.println("请选择:");
            //静态方法只能访问静态变量
            int choose = sc.nextInt();
            switch (choose){
                case 1:
                    addWebSite();
                    break;
                case  2:
                    modifyWebSite();
                    break;
                case 3:
                    dropWebSite();
                    break;
                case 4:
                    queryWebSite();
                    break;
                case 0:
                    System.out.println("退出系统");
                    System.exit(0);
                    break;
                default:
                    System.out.println("对不起,您的选择有误!");
                    break;
            }
        }
    }
    //        String sql ="select * from websites";
//        PreparedStatement pstmt =connection.prepareStatement(sql);
//        ResultSet rs = pstmt.executeQuery();
//        while (rs.next()){
//            System.out.println(rs.getInt(1) +"-"+ rs.getString(2) +"-"+ rs.getString(3)
//                    +"-"+ rs.getInt(4) +"-"+ rs.getString(5));
//        }
//        rs.close();
//        pstmt.close();
//        connection.close();
//    }
    private static void addWebSite() {
        System.out.println("请输入站点名称:");
        String name = sc.next();
        System.out.println("请输入站点URL:");
        String url = sc.next();
        System.out.println("请输入站点alexa:");
        int alexa = sc.nextInt();
        System.out.println("请输入站点所属国家:");
        String country = sc.next();
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            Class.forName((JDBC_DRIVER));
            conn = DriverManager.getConnection(DB_URL, USER, PASS);
            String sql ="insert into websites values(null,?,?,?,?)";
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1,name);
            pstmt.setString(2,url);
            pstmt.setInt(3,alexa);
            pstmt.setString(4,country);
            pstmt.executeUpdate();
            System.out.println("添加站点成功!");
        }catch (SQLException se){
            se.printStackTrace();
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try{
                if(pstmt!=null) pstmt.close();
            }catch (SQLException se2){

            }
            try{
                if(conn!=null) conn.close();
            }catch (SQLException se){
                se.printStackTrace();
            }
        }

    }
    private static void modifyWebSite() {
        System.out.println("请输入要修改的站点名称:");
        String name = sc.next();
        System.out.println("请输入新站点URL:");
        String url = sc.next();
        System.out.println("请输入新站点alexa:");
        int alexa = sc.nextInt();
        System.out.println("请输入新站点所属国家:");
        String country = sc.next();
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            Class.forName((JDBC_DRIVER));
            conn = DriverManager.getConnection(DB_URL, USER, PASS);
            String sql ="update websites set url=?,alexa= ?,country=? where name=?";
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1,name);
            pstmt.setString(2,url);
            pstmt.setInt(3,alexa);
            pstmt.setString(4,country);
            pstmt.executeUpdate();
            System.out.println("修改站点成功!");
        }catch (SQLException se){
            se.printStackTrace();
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try{
                if(pstmt!=null) pstmt.close();
            }catch (SQLException se2){

            }
            try{
                if(conn!=null) conn.close();
            }catch (SQLException se){
                se.printStackTrace();
            }
        }

    }
    private static void dropWebSite() {
        System.out.println("请输入要删除的站点名称:");
        String name = sc.next();
//        System.out.println("请输入站点URL:");
//        String url = sc.next();
//        System.out.println("请输入站点alexa:");
//        int alexa = sc.nextInt();
//        System.out.println("请输入站点所属国家:");
//        String country = sc.next();
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            Class.forName((JDBC_DRIVER));
            conn = DriverManager.getConnection(DB_URL, USER, PASS);
            String sql ="delete from websites where name=?";
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1,name);
//            pstmt.setString(2,url);
//            pstmt.setInt(3,alexa);
//            pstmt.setString(4,country);
            pstmt.executeUpdate();
            System.out.println("删除站点成功!");
        }catch (SQLException se){
            se.printStackTrace();
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try{
                if(pstmt!=null) pstmt.close();
            }catch (SQLException se2){

            }
            try{
                if(conn!=null) conn.close();
            }catch (SQLException se){
                se.printStackTrace();
            }
        }

    }
    private static void queryWebSite() {
//        System.out.println("请输入要查询的站点名称:");
//        String name = sc.next("name");
//        System.out.println("请输入站点URL:");
//       String url = sc.next("url");
//        System.out.println("请输入站点alexa:");
//        int alexa = sc.nextInt(Integer.parseInt("alexa"));
//        System.out.println("请输入站点所属国家:");
//        String country = sc.next("country");

        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            Class.forName((JDBC_DRIVER));
            conn = DriverManager.getConnection(DB_URL, USER, PASS);
            Statement stmt = conn.createStatement();
            String sql ="SELECT id,name,url FROM websites";
            ResultSet rs = stmt.executeQuery(sql);
            //pstmt = conn.prepareStatement(sql);
//            pstmt.setString(name);
//            pstmt.setString(2,url);
//            pstmt.setInt(3,alexa);
//            pstmt.setString(4,country);
//            System.out.print("name");
//            System.out.print("url");
//            System.out.print("alexa");
//            System.out.print("country");
//            System.out.print("\n");
            //pstmt.executeQuery();
            // System.out.println("查询站点成功!");
            while (rs.next()){
                int id =rs.getInt("id");
                String name = rs.getString("name");
                String url = rs.getString("url");
                System.out.print("id"+":"+id+"-");
                System.out.print("name"+":"+name+"-");
                System.out.print("url"+":"+url);
                System.out.print("\n");
                System.out.println("查询站点成功!");
            }
            rs.close();
            stmt.close();
            conn.close();
        }catch (SQLException se){
            se.printStackTrace();
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try{
                if(pstmt!=null) pstmt.close();
            }catch (SQLException se2){

            }
            try{
                if(conn!=null) conn.close();
            }catch (SQLException se){
                se.printStackTrace();
            }
        }

    }
}

运行结果如下:

 

查看MySQL里面的表信息可以看到信息添加成功了。 

 

 修改站点信息

 删除站点

 删除之后的恢复为原来的情况

最后退出系统。

3.4 Java代码模块讲解

3.4.1 Java Scanner 类

java.util.Scanner 是 Java5 的新特征,我们可以通过 Scanner 类来获取用户的输入。

下面是创建 Scanner 对象的基本语法:

Scanner s = new Scanner(System.in);

Scanner 类的 next() 与 nextLine() 方法获取输入的字符串,在读取数据前我们一般需要 使用 hasNext 与 hasNextLine 判断是否还有输入的数据。

next() 、nextInt() 、nextLine() 区别

next():

  • 1、一定要读取到有效字符后才可以结束输入。
  • 2、对输入有效字符之前遇到的空白,next() 方法会自动将其去掉。
  • 3、只有输入有效字符后才将其后面输入的空白作为分隔符或者结束符。
  • next() 不能得到带有空格的字符串。

nextLine():

  • 1、以Enter为结束符,也就是说 nextLine()方法返回的是输入回车之前的所有字符。
  • 2、可以获得空白。

如果要输入 int 或 float 类型的数据,在 Scanner 类中也有支持,但是在输入之前最好先使用 hasNextXxx() 方法进行验证,再使用 nextXxx() 来读取。

nextInt()、nextLine()区别:

  • 1.nextInt()只会读取数值,剩下"\n"还没有读取,并将cursor放在本行中。
  • 2.nextLine()会读取"\n",并结束(nextLine() reads till the end of line \n)。
  • 3.如果想要在nextInt()后读取一行,就得在nextInt()之后额外加上cin.nextLine()

nextInt() 一定要读取到有效字符后才可以结束输入,对输入有效字符之前遇到的空格键、Tab键或Enter键等结束符,nextInt() 方法会自动将其去掉,只有在输入有效字符之后,nextInt()方法才将其后输入的空格键、Tab键或Enter键等视为分隔符或结束符。简单地说,nextInt()查找并返回来自此扫描器的下一个完整标记。完整标记的前后是与分隔模式匹配的输入信息,所以next方法不能得到带空格的字符串。
  而nextLine() 方法的结束符只是Enter键,即nextLine() 方法返回的是Enter键之前的所有字符,它是可以得到带空格的字符串的。
  可以看到,nextLine() 自动读取了被nextInt() 去掉的Enter作为他的结束符,所以没办法给s2从键盘输入值。经过验证,我发现其他的next的方法,如double nextDouble() , float nextFloat() , int nextInt() 等与nextLine() 连用时都存在这个问题,解决的办法是:在每一个 next() 、nextDouble() 、 nextFloat()、nextInt() 等语句之后加一个nextLine() 语句,将被next() 去掉的Enter结束符过滤掉。

此处使用的是scanner对象的nextInt()方法,使用switch-case分支进行判断需要执行的选项是那个。

Scanner sc =new Scanner(System.in);
    int choose = sc.nextInt();
        switch (choose){
                case 1:
                    addWebSite();
                    break;
                case  2:
                    modifyWebSite();
                    break;
                case 3:
                    dropWebSite();
                    break;
                case 4:
                    queryWebSite();
                    break;
                case 0:
                    System.out.println("退出系统");
                    System.exit(0);
                    break;
                default:
                    System.out.println("对不起,您的选择有误!");
                    break;
            }

在新定义的方法上面按住alt+回车既可以出现快捷方式,点击第一个创建一个方法。 

 创建完成之后新增while(true)让程序可以一直执行,程序的中断将会由输入的0来决定退出去。

 完整的这一块代码

public static void main(String[] args) throws SQLException {
        while (true) {
            System.out.println("***********************************");
            System.out.println("*********** 站点管理系统  ***********");
            System.out.println("*********** 1.新增站点   ***********");
            System.out.println("*********** 2.修改站点   ***********");
            System.out.println("*********** 3.删除站点   ***********");
            System.out.println("*********** 4.查询站点   ***********");
            System.out.println("*********** 0.退出系统   ***********");
            System.out.println("**********************************");
            System.out.println("请选择:");
            Scanner sc =new Scanner(System.in);
            int choose = sc.nextInt();
            switch (choose){
                case 1:
                    addWebSite();
                    break;
                case  2:
                    modifyWebSite();
                    break;
                case 3:
                    dropWebSite();
                    break;
                case 4:
                    queryWebSite();
                    break;
                case 0:
                    System.out.println("退出系统");
                    System.exit(0);
                    break;
                default:
                    System.out.println("对不起,您的选择有误!");
                    break;
            }
        }
    }

3.4.2 系统添加数据模块方法

例如以下的方法

private static void dropWebSite() {
        System.out.println("请输入要删除的站点名称:");
        //sc.next方法将不会用到
        //前面设置的sc变量是只能在main方法里面使用,要想使用需要将sc变量放在外面使用
}

解决方法:将sc变量放在main方法外面即可。变成整个类的作用方法

 虽然提出来了,但是scanner的方法仍然不能使用,会出错,原因是sc为成员变量,main是静态的方法,静态的方法只能访问静态的方法,不能访问类里面的变量,需要将scanner变成一个静态的变量。

加入关键字static即可访问其方法

 

 接下来继续编写方法原来实现相关功能

3.4.3  编辑MySQL与druid依赖

官方的网站链接如下:

Maven Repository: Search/Browse/Explore (mvnrepository.com)

在官方网站里面直接搜素需要的依赖即可

 选择mysql搜素,选择访问比较多的即可

 红色框住的是8.0版本以上的,选择自己的对应版本即可。此处小编的版本为8.0的版本,选择这个即可

 

 点击此处蓝色框住的部分即可复制,出现红色的提示即是复制成功

 代码部分

<dependencies>
        <dependency>
            <groupId>com.mysql</groupId>
            <artifactId>mysql-connector-j</artifactId>
            <version>8.0.31</version>
        </dependency>

</dependencies>

 粘贴过来的显示为红色,如果之前未安装此组件的话,会有一个刷新的图标,点击一下,完成安装,安装完成之后红色部分会变成白色。

 

出现这种情况既是安装完成。 

搜索druid依赖,点击第一个即可

 选择自己的对应版本

 

 代码部分如下:

<!-- https://mvnrepository.com/artifact/com.alibaba/druid -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.2.8</version>
        </dependency>

粘贴上述代码即可。

3.4.4 编辑插入数据方法

前面先给用户一个输入区,并且将输入的内容编辑为相关的变量暂时存在内存区,此时的数据并没有保存到数据库里面。

下面加入配置文件原来访问数据库,设置与前面的2.3.2 编辑配置文件相同。

利用类加载器原来加载配置文件,让文件以流的形式读进来,

选择alt+enter,选择第二个,让异常抛出

此处还有异常,将异常的这段代码放在try-catch里面捕获一下抛出

 这样捕获异常

 

捕获完成之后会自动放在catch语句里面 

// 加载配置文件
            Properties prop = new Properties();
            InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("druid.properties");
            try {
                prop.load(is);
                // 获取数据库连接池对象
                DataSource ds = DruidDataSourceFactory.createDataSource(prop);
                // 获取连接
                Connection connection = ds.getConnection();

            } catch (IOException e) {
                e.printStackTrace();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }

此处创建一个预编译对象

 完成之后使用其方法获取相关的数据,将其插入到数据库里面。

完整的插入代码

private static void addWebSite() {
            System.out.println("请输入站点名称:");
            String name = sc.next();
            System.out.println("请输入站点URL:");
            String url = sc.next();
            System.out.println("请输入站点alexa:");
            int alexa = sc.nextInt();
            System.out.println("请输入站点所属国家:");
            String country = sc.next();

            // 1 加载配置文件
            Properties prop = new Properties();
            InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("druid.properties");
            try {
                prop.load(is);
                // 2 获取数据库连接池对象
                DataSource ds = DruidDataSourceFactory.createDataSource(prop);
                // 3 获取连接
                Connection connection = ds.getConnection();
                // 4 执行SQL
                //插入SQL语句,?为占位符
                String sql ="insert into websites values(null,?,?,?,?)";
                //创建PreparedStatement预编译执行对象,将传入的SQL语句读出来。
                PreparedStatement stmt = connection.prepareStatement(sql);
                //设置参数
                stmt.setString(1,name);
                stmt.setString(2,url);
                stmt.setInt(3,alexa);
                stmt.setString(4,country);
                stmt.executeUpdate();
                // 获取插入完成的值,一般插入完成之后会出现·插入影响的行数
                // 将返回变量的类型设置为int型
                int row = stmt.executeUpdate();
                //提示一下
                if (row != 0){
                    System.out.println("添加站点成功!");
                }
            } catch (IOException e) {
                e.printStackTrace();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }
}

3.4.5 编辑查询代码

PS:此处为未经优化的代码段 ,后续有优化之后的代码段。

在上述的插入代码的基础之上编辑查询代码即可。

private static void queryWebSite() {
            // 1 加载配置文件
            Properties prop = new Properties();
            InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("druid.properties");
            try {
                prop.load(is);
                // 2 获取数据库连接池对象
                DataSource ds = DruidDataSourceFactory.createDataSource(prop);
                // 3 获取连接
                Connection connection = ds.getConnection();
                // 4 执行SQL
                //插入SQL语句,?为占位符
                String sql ="select * from websites";
                //创建PreparedStatement预编译执行对象,将传入的SQL语句读出来。
                PreparedStatement stmt = connection.prepareStatement(sql);
                //设置返回的参数,此处的返回值为结果集
                ResultSet rs = stmt.executeQuery();
                // 获取查询到的结果集
                while (rs.next()){
                    // 将结果集拼接起来
                    System.out.println(rs.getInt(1) + "-" + rs.getString(2) + "-" +  rs.getString(3)
                            + "-" +  rs.getInt(4) + "-" +  rs.getString(5));
                }

            } catch (IOException e) {
                e.printStackTrace();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }

        }

此处的获取数据库连接可以创建一个DruidUtil类来专门获取数据库连接

工具类的完整代码【此处就是将获取数据库连接的部分一一个类的形式创建,此时可以优化一下之前的代码】

优化之后的插入数据代码

private static void addWebSite() {
            System.out.println("请输入站点名称:");
            String name = sc.next();
            System.out.println("请输入站点URL:");
            String url = sc.next();
            System.out.println("请输入站点alexa:");
            int alexa = sc.nextInt();
            System.out.println("请输入站点所属国家:");
            String country = sc.next();

           try {
                // 3 获取连接,此处使用类方法进行调用。
                Connection connection = DruidUtil.getConn();
                // 4 执行SQL
                //插入SQL语句,?为占位符
                String sql ="insert into websites values(null,?,?,?,?)";
                //创建PreparedStatement预编译执行对象,将传入的SQL语句读出来。
                PreparedStatement stmt = connection.prepareStatement(sql);
                //设置参数
                stmt.setString(1,name);
                stmt.setString(2,url);
                stmt.setInt(3,alexa);
                stmt.setString(4,country);
                stmt.executeUpdate();
                // 获取插入完成的值,一般插入完成之后会出现·插入影响的行数
                // 将返回变量的类型设置为int型
                int row = stmt.executeUpdate();
                //提示一下
                if (row != 0){
                    System.out.println("添加站点成功!");
                }
            // 原先的异常处理也就不再需要,直接删除即可
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

优化之后的查询代码

private static void queryWebSite() {
            try {
                // 3 获取连接
                Connection connection = DruidUtil.getConn();
                // 4 执行SQL
                //插入SQL语句,?为占位符
                String sql ="select * from websites";
                //创建PreparedStatement预编译执行对象,将传入的SQL语句读出来。
                PreparedStatement stmt = connection.prepareStatement(sql);
                //设置返回的参数,此处的返回值为结果集
                ResultSet rs = stmt.executeQuery();
                // 获取查询到的结果集
                while (rs.next()){
                    // 将结果集拼接起来
                    System.out.println(rs.getInt(1) + "-" + rs.getString(2) + "-" +  rs.getString(3)
                            + "-" +  rs.getInt(4) + "-" +  rs.getString(5));
                }

            } catch (SQLException throwables) {
                throwables.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

3.4.6  完整的优化后的代码

package com.ambow.druid;

import java.sql.*;
import java.util.Scanner;

public class work01 {
        static Scanner sc =new Scanner(System.in);
        public static void main(String[] args){
            while(true) {
                System.out.println("***********************************");
                System.out.println("*********** 站点管理系统  ***********");
                System.out.println("*********** 1.新增站点   ***********");
                System.out.println("*********** 2.修改站点   ***********");
                System.out.println("*********** 3.删除站点   ***********");
                System.out.println("*********** 4.查询站点   ***********");
                System.out.println("*********** 0.退出系统   ***********");
                System.out.println("**********************************");
                System.out.println("请选择:");
                Scanner sc = new Scanner(System.in);
                int choose = sc.nextInt();
                switch (choose) {
                    case 1:
                        addWebSite();
                        break;
                    case 2:
                        modifyWebSite();
                        break;
                    case 3:
                        dropWebSite();
                        break;
                    case 4:
                        queryWebSite();
                        break;
                    case 0:
                        System.out.println("退出系统");
                        System.exit(0);
                        break;
                    default:
                        System.out.println("对不起,您的选择有误!");
                        break;
                }
            }
        }
        private static void addWebSite() {
            System.out.println("请输入站点名称:");
            String name = sc.next();
            System.out.println("请输入站点URL:");
            String url = sc.next();
            System.out.println("请输入站点alexa:");
            int alexa = sc.nextInt();
            System.out.println("请输入站点所属国家:");
            String country = sc.next();
           try {
                // 3 获取连接,此处使用类方法进行调用。
                Connection connection = DruidUtil.getConn();
                // 4 执行SQL
                //插入SQL语句,?为占位符
                String sql ="insert into websites values(null,?,?,?,?)";
                //创建PreparedStatement预编译执行对象,将传入的SQL语句读出来。
                PreparedStatement stmt = connection.prepareStatement(sql);
                //设置参数
                stmt.setString(1,name);
                stmt.setString(2,url);
                stmt.setInt(3,alexa);
                stmt.setString(4,country);
                stmt.executeUpdate();
                // 获取插入完成的值,一般插入完成之后会出现·插入影响的行数
                // 将返回变量的类型设置为int型
                int row = stmt.executeUpdate();
                //提示一下
                if (row != 0){
                    System.out.println("添加站点成功!");
                }
            // 原先的异常处理也就不再需要,直接删除即可
            } catch (SQLException e) {
                e.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        private static void modifyWebSite() {
            System.out.println("请输入要修改的站点名称:");
            String name = sc.next();
            System.out.println("请输入新站点URL:");
            String url = sc.next();
            System.out.println("请输入新站点alexa:");
            int alexa = sc.nextInt();
            System.out.println("请输入新站点所属国家:");
            String country = sc.next();
            try {
                // 3 获取连接
                Connection connection = DruidUtil.getConn();
                // 4 执行SQL
                //插入SQL语句,?为占位符
                String sql ="update websites set url=?,alexa= ?,country=? where name=?";
                //创建PreparedStatement预编译执行对象,将传入的SQL语句读出来。
                PreparedStatement stmt = connection.prepareStatement(sql);
                //设置参数
                stmt = connection.prepareStatement(sql);
                stmt.setString(1,name);
                stmt.setString(2,url);
                stmt.setInt(3,alexa);
                stmt.setString(4,country);
                stmt.executeUpdate();
                int row = stmt.executeUpdate();
                //提示一下
                if (row != 0){
                    System.out.println("修改站点成功!");
                }
            } catch (SQLException e) {
                e.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }

        }
        private static void dropWebSite() {
            System.out.println("请输入要删除的站点名称:");
            String name = sc.next();
            try {
                // 3 获取连接
                Connection connection = DruidUtil.getConn();
                // 4 执行SQL
                //插入SQL语句,?为占位符
                String sql ="delete from websites where name=?";
                //创建PreparedStatement预编译执行对象,将传入的SQL语句读出来。
                PreparedStatement stmt = connection.prepareStatement(sql);
                //设置参数
                stmt.setString(1,name);
                stmt.executeUpdate();
                // 获取插入完成的值,一般插入完成之后会出现·插入影响的行数
                // 将返回变量的类型设置为int型
                int row = stmt.executeUpdate();
                //提示一下
                if (row != 0){
                    System.out.println("删除站点成功!");
                }
            } catch (SQLException e) {
                e.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        private static void queryWebSite() {
            try {
                // 3 获取连接
                Connection connection = DruidUtil.getConn();
                // 4 执行SQL
                //插入SQL语句,?为占位符
                String sql ="select * from websites";
                //创建PreparedStatement预编译执行对象,将传入的SQL语句读出来。
                PreparedStatement stmt = connection.prepareStatement(sql);
                //设置返回的参数,此处的返回值为结果集
                ResultSet rs = stmt.executeQuery();
                // 获取查询到的结果集
                while (rs.next()){
                    // 将结果集拼接起来
                    System.out.println(rs.getInt(1) + "-" + rs.getString(2) + "-" +  rs.getString(3)
                            + "-" +  rs.getInt(4) + "-" +  rs.getString(5));
                }
            } catch (SQLException e) {
                e.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
}

思考——如何优化上述的Java代码? 

优化方案——使用分层将代码分为几个模块

1、视图层

2、持久层 / 数据访问层 Dao -- Data  Access  Object  数据访问层

优化的方案将会在后续的文章当中给出具体的操作。

jdbc是硬编码的方式

SQL语句也是硬编码,缺点是不易维护

 mybatis框架

总结

以上就是今天的内容~

欢迎大家点赞👍,收藏⭐,转发🚀,
如有问题、建议,请您在评论区留言💬哦。

最后:转载请注明出处!!!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/824525.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

解决项目加载时空白页面

背景&#xff1a;当前端项目加载时&#xff0c;遇到网络不稳定或更新项目时&#xff0c;出现长时间白屏情况&#xff0c;对用户体验非常不友好。 解决方法 CSN加速增加带宽前端页面修改 本文就第三点展开 index.html页面 &#xff08;public文件夹下&#xff09; <!DOCTYPE…

STM32F4_外部SRAM

目录 前言 1. SRAM控制原理 1.1 SRAM功能框图 1.2 SRAM读写时序 2. FSMC简介 2.1 FSMC架构 2.2 FSMC地址映射 2.3 FSMC控制SRAM时序 3. FSMC结构体 4. 库函数配置FSMC 5. 实验程序 5.1 main.c 5.2 SRAM.c 5.3 SRAM.h 前言 STM32F4自带了192K字节的SRAM&#xff1…

免费logo生成网官网分享,轻松生成专属logo

如果你正在寻找一种快速、廉价的方式来创建一个专业的商标&#xff0c;那么免费的logo生成器可能是你想要的。这些生成器可以帮助你在几分钟内创建一个标志&#xff0c;而无需花费大量的时间和金钱。 有些小伙伴会说自己没有设计的经验&#xff0c;对于logo设计也没有太多的构思…

如何能够高效实现表格中的分权限编辑功能

摘要&#xff1a;本文由葡萄城技术团队于CSDN原创并首发。转载请注明出处&#xff1a;葡萄城官网&#xff0c;葡萄城为开发者提供专业的开发工具、解决方案和服务&#xff0c;赋能开发者。 在表格类填报需求中&#xff0c;根据当前登录用户的不同等级&#xff0c;能填报的区域会…

基于SpringBoot+Vue的超市进销存系统设计与实现(源码+LW+部署文档等)

博主介绍&#xff1a; 大家好&#xff0c;我是一名在Java圈混迹十余年的程序员&#xff0c;精通Java编程语言&#xff0c;同时也熟练掌握微信小程序、Python和Android等技术&#xff0c;能够为大家提供全方位的技术支持和交流。 我擅长在JavaWeb、SSH、SSM、SpringBoot等框架…

LRU缓存淘汰算法详解与实现

目录 1.什么是LRU算法 2.LRU算法原题描述 3.LRU算法设计 4.LRU算法细节分析 5.代码实现 1.什么是LRU算法 就是一种缓存淘汰策略。 计算机的缓存容量有限&#xff0c;如果缓存满了就要删除一些内容&#xff0c;给新内容腾位置。但问题是&#xff0c;删除哪些内容呢&#…

向专家学习:APP开发的成功窍门

尽管有诸多障碍&#xff0c;但 APP开发仍然是企业的最佳选择。开发一款成功的 APP应用程序是一项具有挑战性的工作&#xff0c;但您仍然可以在以下几个方面做出改进。 这是一个快速变化的行业&#xff0c;也是一个可以通过学习获得经验和知识的行业。如果您不知道如何解决问题…

STM32CUBUMX配置RS485 modbus STM32(从机)亲测可用

———————————————————————————————————— ⏩ 大家好哇&#xff01;我是小光&#xff0c;嵌入式爱好者&#xff0c;一个想要成为系统架构师的大三学生。 ⏩最近在开发一个STM32H723ZGT6的板子&#xff0c;使用STM32CUBEMX做了很多驱动&#x…

JSP--Java的服务器页面

jsp是什么&#xff1f; jsp的全称是Java server pages,翻译过来就是java的服务器页面。 jsp有什么作用&#xff1f; jsp的主要作用是代替Servlet程序回传html页面的数据&#xff0c;因为Servlet程序回传html页面数据是一件非常繁琐的事情&#xff0c;开发成本和维护成本都非常高…

zabbix5.0安装配置和日常管理使用笔记

服务端配置&#xff1a; zabbix官网&#xff08;有软件下载和安装步骤说明&#xff09; https://www.zabbix.com/cn/download 关selinux和防火墙 iptables -L 查看全部清空 建议给4G内存空间 获取zabbix下载镜像源 rpm -Uvh https://mirrors.aliyun.com/zabbix/zabbix/5.0/…

Slurm--资源管理系统

Slurm–资源管理系统 开源软件 SLURM 全称 Simple Linux Utility for Resource Management开源分布式资源管理软件可用于大型计算节点集群的高度可伸缩的集群管理器和作业调度系统 提供高效的资源与作业管理 状态监控资源管理作业调度 是用户使用计算资源的接口 作业提交 / 运…

【Vue3+Ts+Vite】配置页面切换过渡动画

文章目录 一、先看效果二、全量代码三、注意事项虽然Vue3支持 template 下存在多个根节点&#xff0c;但是 transition 过渡动画并不支持&#xff0c;要实现过渡动画的页面&#xff0c;都需要有一个根标签包裹页面内容&#xff0c;否则就会报如下警告: 四、相关文章友链本专栏记…

Vue 组件和计算属性(二)

一、组件 1.1 什么是组件 组件是可复用的 Vue 实例&#xff0c;说白了就是一组可以重复使用的模板&#xff0c;跟 JSTL 的自定义标签、Thymeleaf 的 th:fragment 等框架有着异曲同工之妙。通常一个应用会以一棵嵌套的组件树的形式来组织。 例如&#xff0c;你可能会有页头、侧…

vue + element UI Table 表格 利用插槽是 最后一行 操作 的边框线 不显示

在屏幕比例100%时 el-table添加border属性 使用作用域插槽 会不显示某侧的边框线&#xff0c;屏幕比例缩小或放大都展示 // 修复列的 边框线消失的bug thead th:not(.is-hidden):last-child {right:-1px;// 或者//border-left: 1px solid #ebeef5; } .el-table__row{td:not(.i…

Docker 容器转为镜像

# 容器转成镜像并指定镜像名称与版本号 # commit 时原有容器挂载的目录是不会被写入到新的镜像中去的&#xff0c;数据卷相关的都不会生效 # 但是 root 目录下新建的内容会写入到新的镜像中去 $ docker commit 容器ID 新镜像名称:版本号 $ docker commit -m"描述信息"…

2023年电赛---运动目标控制与自动追踪系统(E题)OpenMV方案

前言 &#xff08;1&#xff09;废话少说&#xff0c;很多人可能无法访问GitHub&#xff0c;所以我直接贴出可能要用的代码。此博客还会进行更新&#xff0c;先贴教程和代码 &#xff08;2&#xff09;视频教程&#xff1a; https://singtown.com/learn/49603/ &#xff08;3&a…

大数据技术之Clickhouse---入门篇---数据类型、表引擎

星光下的赶路人star的个人主页 今天没有开始的事&#xff0c;明天绝对不会完成 文章目录 1、数据类型1.1 整型1.2 浮点型1.3 布尔型1.4 Decimal型1.5 字符串1.6 枚举类型1.7 时间类型1.8 数组 2、表引擎2.1 表引擎的使用2.2 TinyLog2.3 Memory2.4 MergeTree2.4.1 Partition by分…

华为OD机试真题 JavaScript 实现【取出尽量少的球】【2023Q1 200分】,附详细解题思路

目录 一、题目描述游戏规则如下&#xff1a;限制规则一&#xff1a;限制规则二&#xff1a; 二、输入描述三、输出描述四、解题思路五、JavaScript算法源码六、效果展示1、输入2、输出3、说明 华为OD机试 2023B卷题库疯狂收录中&#xff0c;刷题点这里 刷的越多&#xff0c;抽中…

《golang设计模式》第一部分·创建型模式-04-抽象工厂模式(Abstract Factory)

文章目录 1. 概述1.1 角色1.2 类图 2. 代码示例2.1 设计2.2 代码2.3 类图 1. 概述 1.1 角色 AbstractFactory&#xff08;抽象工厂&#xff09;&#xff1a;它声明了一组用于创建产品的方法&#xff0c;每一个方法对应一种产品。ConcreteFactory&#xff08;具体工厂&#xf…

phpstudy 进行 composer 全局配置

背景 因为注意到&#xff0c;使用 phpStudy 进行环境搭建时&#xff0c;有时需要使用 composer 每次都需要查找资料进行配置&#xff0c; 在此进行记录笔记&#xff0c;方便有需要的道友借鉴 配置 版本&#xff1a;composer1.8.5&#xff08;phpStudy8 当前只能安装这一个版本…