顺序,先下载 MysqL 驱动 下载地址
下载完成后将解压后如下所示的 .jar 文件拖入 lib 包再右键添加为库。
再安装 Database Navigator 插件建立与 MysqL 数据库的连接,连接参数(用户名和密码要填正确!)输入完后一定要按 Apply,只按确定成功不了。
这一段是对数据库操作的代码,首先定义一些与 MysqL 相关参数,然后实现了简单的基本插入操作
更多操作可以在上面累加,比较容易
// MysqL.java
package mydatabase;
import java.sql.*;
public class MysqL {
// 定义数据库连接 url
private String dburl = null;
// 定义数据库连接
private Connection conn = null;
// 定义数据返回结果集
private ResultSet rs = null;
// 定义数据库状态
private PreparedStatement stmt = null;
// 定义数据库用户名
private String username = null;
// 定义数据库连接密码
private String password = null;
// 定义数据库驱动方式
private String dbdriver = null;
// 设置数据库连接 url 的方法
public void setDburl(String dburl){
this.dburl = dburl;
}
// 返回当前实例数据库连接 url
public String getDburl(){
return dburl;
}
// 设置数据库用户名的方法
public void setUsername(String username){
this.username = username;
}
// 返回当前实例化数据库用户名
public String getUsername(){
return username;
}
// 设置数据库连接的方法
public void setPassword(String password){
this.password = password;
}
// 返回当前实例结果集的方法
public ResultSet getRs(){
return rs;
}
// 设置当前实例结果集的方法
public void setRs(ResultSet rs){
this.rs = rs;
}
// 返回当前实例数据库连接密码
public String getpassword(){
return password;
}
// 设置数据库驱动方式的方法
public void setDbdriver(String dbdriver){
this.dbdriver = dbdriver;
}
// 返回当前实例数据库驱动方式的方法
public String getDbdriver(){
return dbdriver;
}
// 创建数据库连接的方法
Connection CreateConnection(String dburl,String username,String password)throws Exception{
setDburl(dburl);
setUsername(username);
setPassword(password);
Class.forName(getDbdriver());
// 根据数据库路径、用户名和密码创建连接并返回该连接
return DriverManager.getConnection(dburl,username,password);
}
// 关闭结果集的方法
public void CloseRS(){
try{
rs.close();
}catch (sqlException e){
System.out.println("关闭结果集时发生错误!");
}
}
// 关闭状态的方法
public void CloseStmt(){
try{
stmt.close();
}catch (sqlException e){
System.out.println("关闭状态时发生错误!");
}
}
// 关闭连接的方法
public void CloseConnection(){
try{
conn.close();
}catch (sqlException e){
System.out.println("关闭连接时发生错误!");
}
}
// 根据参数执行插入操作
void executeInsert(String id,String name)throws Exception {
try {
conn = CreateConnection(getDburl(), getUsername(), getpassword());
stmt = conn.prepareStatement("insert into stu values(?,?)");
stmt.setString(1, id);
stmt.setString(2, name);
stmt.executeUpdate();
} catch (sqlException ex) {
System.err.println(ex.getMessage());
}
}
}
下面是启动程序对 MysqL 进行插入操作。
// StartMysqL.java
package mydatabase;
import java.sql.sqlException;
import java.util.Scanner;
public class StartMysqL {
public static void main(String[] args) throws sqlException {
MysqL db = new MysqL();
db.setDburl("jdbc:MysqL://localhost:3306/student?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC");
// MysqL 老版驱动
//db.setDbdriver("com.MysqL.jdbc.Driver");
// MysqL 8.0 以上版本驱动
db.setDbdriver("com.MysqL.cj.jdbc.Driver");
try {
Scanner sc = new Scanner(system.in);
System.out.print("MysqL 用户名:");
String username;
username = sc.next();
db.setUsername(username);
System.out.print("MysqL 密码:");
String password;
password = sc.next();
db.setPassword(password);
}
catch(Exception e){
System.err.print(e.getMessage());
}
String id,name;
Scanner sc = new Scanner(system.in);
System.out.print("请输入要插入的id:");
id = sc.next();
System.out.print("请输入要插入对应id的name:");
name = sc.next();
try {
db.executeInsert(id,name);
} catch (Exception e) {
System.err.println(e.getMessage());
}
finally {
db.CloseRS();
db.CloseStmt();
db.CloseConnection();
}
}
}
结果演示:
这是程序结果
你可以很容易地想到,用一个循环就可以实现一次性插入多条记录。
MysqL 结果
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。