Java 连接操作 MySQL 数据库（增删查改操作）

约定不等于承诺〃 2023-03-13 06:38 16阅读 0赞

###  ###

*  环境
 *  准备工作
 *  增删查改操作

> MySQL 操作有不懂的，可查看我的 [MySQL教程][MySQL]

# 环境 #

*  MySQL 5.5 版本
 *  eclipse
 *  MySQL 连接驱动 `mysql-connector-java-5.1.18-bin.jar`

> mysql8.0之前的版本与之后的版本使用的jar包是不同的，在使用时也有一定的区别。这里，我的 MySQL 版本为 5.5。 连 接 驱 动 链 接 放 在 文 末 ， 需 要 可 自 行 下 载 \\color\{red\}连接驱动链接放在文末，需要可自行下载 连接驱动链接放在文末，需要可自行下载

# 准备工作 #

*  将 jar 包添加到项目中，右键项目，如下，选择`Configure Build Path...`  
    ![format_png][]
 *  将刚才下载好的 jar 包添加进去即可  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5MzM5NDY3_size_16_color_FFFFFF_t_70]

# 增删查改操作 #

*  首先，建立一个数据库模板 `DBConfig.java`

> 注意：要提前建立一个数据库，然后在`JDBC_URL`中填写你自己的数据库名称

/* * 若尘 */
    package test;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.Statement;
    
    
    /** * 数据库连接和关闭工具类 * @author ruochen * @version 1.0 */
    public class DBConfig { 
    	/** 定义数据库驱动类名称 */
    	private static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
    	
    	/** 数据库连接地址 */
    	private static final String JDBC_URL = "jdbc:mysql://127.0.0.1:3306/JavaDB?characterEncoding=utf8";
    	
    	/** 数据库用户名 */
    	private static final String JDBC_USERNAME = "root";
    	
    	/** 数据库密码 */
    	private static final String JDBC_PASSWORD = "root";
    	
    	/** 数据库连接对象 */
    	private static Connection conn = null;
    	
    	/** * 获得链接 * @return */
    	public static Connection getConnection() { 
    		try { 
    			try { 
    				// 加载驱动程序
    				Class.forName(JDBC_DRIVER);
    				System.out.println("加载成功");
    			} catch (java.lang.ClassNotFoundException e) { 
    				System.out.println("ForName: " + e.getMessage());
    			}
    			conn = DriverManager.getConnection(JDBC_URL, JDBC_USERNAME, JDBC_PASSWORD);
    		} catch (Exception e) { 
    			e.printStackTrace();
    		}
    		return conn;
    	}
    	
    	public static void closeConnection(ResultSet rs, Statement ps, Connection conn) { 
    		try { 
    			if (null != rs) { 
    				rs.close();
    			}
    			if (null != ps) { 
    				ps.close();
    			}
    			if (null != conn) { 
    				conn.close();
    			}
    		} catch (Exception e) { 
    			System.out.println("Close connection error");
    			e.printStackTrace();
    		}
    	}
    }

*  建表操作 `CreateTest.java`

/* * 若尘 */
    package test;
    
    import java.sql.Connection;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    /** * JDBC链接数据库，创建数据表 * @author ruochen * @version 1.0 */
    public class CreateTest { 
    	public static void main(String[] args) { 
    		Connection conn = DBConfig.getConnection();
    		try { 
    			Statement st = conn.createStatement();
    			ResultSet re = conn.getMetaData().getTables(null, null, "student", null);
    			if (re.next()) { 
    				System.out.println("表已经存在");
    			} else { 
    			// 建表语句
    			String sql = "create table student ( "
    					+ "id char(10),"
    					+ "name char(16),"
    					+ "score integer" + ")";
    			st.executeUpdate(sql);
    			System.out.println("创建成功");
    			}
    			DBConfig.closeConnection(re, st, conn);
    		} catch (SQLException e) { 
    			System.out.println("SQLException: " + e.getMessage());
    		}
    	}
    
    }

加载成功
    创建成功

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5MzM5NDY3_size_16_color_FFFFFF_t_70 1]

*  插入操作 `InsertTest.java`

/* * 若尘 */
    package test;
    
    import java.sql.Connection;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    /** * 数据表中插入数据 * @author ruochen * @version 1.0 */
    public class InsertTest { 
    
    	public static void main(String[] args) { 
    		Connection conn = DBConfig.getConnection();
    		try { 
    			Statement st = conn.createStatement();
    			String r1 = "insert into student values('0001', '小王', 80)";
    			String r2 = "insert into student values('0002', '小李', 82)";
    			String r3 = "insert into student values('0003', '小张', 90)";
    			
    			st.executeUpdate(r1);
    			st.executeUpdate(r2);
    			st.executeUpdate(r3);
    			System.out.println("插入成功");
    			
    			DBConfig.closeConnection(null, st, conn);
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    	}
    }

加载成功
    插入成功

![在这里插入图片描述][20200512161026348.png]

*  更新操作 `UpdateTest.java`

/* * 若尘 */
    package test;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    
    /** * 更新数据库操作 * @author ruochen * @version 1.0 */
    public class UpdateTest { 
    
    	public static void main(String[] args) { 
    		Connection conn = DBConfig.getConnection();
    		
    		String[] id = { "0002", "0003"};
    		int[] score = { 70, 60};
    		PreparedStatement ps;
    		try { 
    			ps = conn.prepareStatement("Update student set score=? where id=?");
    			int i = 0, idlen = id.length;
    			do { 
    				ps.setInt(1, score[i]);
    				ps.setString(2, id[i]);
    				ps.executeUpdate();
    				System.out.println("修改成功");
    				++i;
    			} while (i < idlen);
    			DBConfig.closeConnection(null, ps, conn);
    		} catch (Exception e) { 
    			e.printStackTrace();
    		}
    	}
    }

加载成功
    修改成功
    修改成功

![在这里插入图片描述][20200512161145322.png]

*  删除、查询操作 `SearchTest.java`

/* * 若尘 */
    package test;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.Statement;
    
    /** * 删除、查询数据库操作 * @author ruochen * @version 1.0 */
    public class SearchTest { 
    	public static void main(String[] args) { 
    		Connection conn = DBConfig.getConnection();
    		try { 
    			Statement st = conn.createStatement(); 
    			PreparedStatement ps = conn.prepareStatement("delete from student where id=?");
    			ps.setString(1, "0002");
    			ps.executeUpdate();
    			System.out.println("删除成功");
    			ResultSet rs = st.executeQuery("select * from student");
    			while (rs.next()) { 
    				System.out.println(rs.getString("id") + "\t"
    						+ rs.getString("name") + "\t" + rs.getShort("score"));
    			}
    			st.close();
    			DBConfig.closeConnection(rs, ps, conn);
    		} catch (Exception e) { 
    			e.printStackTrace();
    		}
    	}
    
    }

加载成功
    删除成功
    0001	小王	80
    0003	小张	60

![在这里插入图片描述][20200512161243519.png]

> mysql-connector-java-5.1.18-bin.jar  
> 链接：https://pan.baidu.com/s/1Ep7pKfFnHq\_S8oN1Z4kaNg  
> 提取码：tz8n

[MySQL]: https://blog.csdn.net/qq_29339467/category_9715943.html
[format_png]: /images/20230312/d7d623e3cf034b809e7251ed5d3ee641.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5MzM5NDY3_size_16_color_FFFFFF_t_70]: /images/20230312/815acde5c56e49bd8c193afbd82ca53f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5MzM5NDY3_size_16_color_FFFFFF_t_70 1]: /images/20230312/7b8278d0be2d4173bcb63ed87ede7637.png
[20200512161026348.png]: /images/20230312/18d3ede5b5eb4e029bc02b03eb4c54bb.png
[20200512161145322.png]: /images/20230312/ab5870dc68e64887b2a637ef7a82e442.png
[20200512161243519.png]: /images/20230312/f67aa61065c9462ca0cfdd4bd5987208.png