Java 连接操作 MySQL 数据库(增删查改操作)【奔跑吧!JAVA】

举报
ruochen 发表于 2021/05/18 21:59:13 2021/05/18
【摘要】 Java 连接操作 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...
  • 将刚才下载好的 jar 包添加进去即可
    在这里插入图片描述

增删查改操作

  • 首先,建立一个数据库模板 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());
		}
	}

}
加载成功
创建成功

在这里插入图片描述

  • 插入操作 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();
		}
	}
}
加载成功
插入成功

在这里插入图片描述

  • 更新操作 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();
		}
	}
}
加载成功
修改成功
修改成功

在这里插入图片描述

  • 删除、查询操作 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

在这里插入图片描述

mysql-connector-java-5.1.18-bin.jar
链接:https://pan.baidu.com/s/1Ep7pKfFnHq_S8oN1Z4kaNg
提取码:tz8n

【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。