第一步下载驱动包
1.mySQL驱动包下载网站
MySQL :: MySQL Community Downloads
第二步安装JDBC驱动
2.Intellij IDEA安装JDBC驱动
示例:在Intellij IDEA下的安装MySQL驱动。
(1)菜单选择:File → Project Stucture(快捷键:Ctrl+Alt+Shift+S)
(2)打开Project Stucture项目结构窗体后,选择:Modules → Dependencies → <Module source> → 点击右边的“+”加符号 → JARs or directories(如下图)。
(3)然后选择JDBC驱动文件:mysql-connector-java-8.0.14.jar。
(4)最后点击“OK”即可,在项目的External Libraries下就能看的加载的JDBC驱动(如下图)。
第三步编写代码
3.JDBC增删改查代码
import java.sql.*;
import java.util.Scanner;
public class MySQl {
/*
*java连接mysql数据库
*1、加载驱动程序
*2、数据库连接字符串"jdbc:mysql://localhost:3306/数据库名?"
*3、数据库登录名
*3、数据库登录密码
*/
// MySQL 8.0 以下版本 - JDBC 驱动名及数据库 URL
//static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
// static final String DB_URL = "jdbc:mysql://localhost:3306/数据库名";
// MySQL 8.0 以上版本 - JDBC 驱动名及数据库 URL
static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
static final String DB_URL = "jdbc:mysql://localhost:3306/t151";
// 数据库的用户名与密码
static final String USER = "root";
static final String PASS = "root";
static Connection conn = null;
static Statement stmt = null;
public static void main(String[] args) throws ClassNotFoundException, SQLException {
Scanner input = new Scanner(System.in);
// 注册 JDBC 驱动
Class.forName(JDBC_DRIVER);
// 打开链接
System.out.println("连接数据库...");
conn = DriverManager.getConnection(DB_URL,USER,PASS);
stmt = conn.createStatement();
String sql;
do {
System.out.println("\t\tMySQl管理系统");
System.out.println("1.新增,2.删除,3.修改,4.查询,0.退出");
System.out.println("请选择:");
switch (input.nextInt()){
case 1: //新增
System.out.println("请输入编号:");
int Id=input.nextInt();
System.out.println("请输入姓名:");
String Name=input.next();
System.out.println("请输入性别:");
String Sex = input.next();
System.out.println("请输入年龄:");
int Age=input.nextInt();
sql= String.format("INSERT INTO students VALUES(%s,'%s','%s',%s)",Id,Name,Sex,Age);
if(stmt.executeUpdate(sql)>0) {
System.out.println("新增成功");
} else {
System.out.println("新增失敗");
}
break;
case 2: //删除
System.out.println("请输入删除编号:");
int DeleteId= input.nextInt();
sql= String.format("DELETE FROM students where Id=%s",DeleteId);
if(stmt.executeUpdate(sql)>0) {
System.out.println("删除成功");
} else {
System.out.println("删除失敗");
}
break;
case 3: //修改
System.out.println("请输入编号:");
int ModifyId=input.nextInt();
System.out.println("请输入姓名:");
String ModifyName=input.next();
System.out.println("请输入性别:");
String ModifySex = input.next();
System.out.println("请输入年龄:");
int ModifyAge=input.nextInt();
sql= String.format("UPDATE students SET Name='%s',Sex='%s',Age=%s WHERE id=%s",ModifyName,ModifySex,ModifyAge,ModifyId);
if(stmt.executeUpdate(sql)>0) {
System.out.println("修改成功");
} else {
System.out.println("修改失敗");
}
break;
case 4: //查询
System.out.println("查询信息:\n");
sql = "select * from students";
ResultSet rs = stmt.executeQuery(sql);
while(rs.next()){
// 通过字段检索
int id = rs.getInt("Id");
String name = rs.getString("Name");
String sex = rs.getString("Sex");
String age = rs.getString("Age");
// 输出数据
System.out.print(" 编号: " + id);
System.out.print(", 姓名: " + name);
System.out.print(", 性别: " + sex);
System.out.print(", 年龄: " + age);
System.out.print("\n");
}
// 完成后关闭
rs.close();
break;
case 0: //退出
System.out.println("退出!");
return;
default:
System.out.println("有误!");
}
}while (true);
}
}
代码运行
谢谢观看!,希望对你有所帮助。