作者:飞天6585_439 | 来源:互联网 | 2023-10-10 20:27
首先你得有个 mysql 账户,自己设置用户名和密码
顺序,先下载 mysql 驱动 下载地址
下载完成后将解压后如下所示的 .jar 文件拖入 lib 包再右键添加为库。
再安装 Database Navigator 插件建立与 mysql 数据库的连接,连接参数(用户名和密码要填正确!)输入完后一定要按 Apply,只按确定成功不了。
如何完成的过程都在代码里,先看代码
这一段是对数据库操作的代码,首先定义一些与 mysql 相关参数,然后实现了简单的基本插入操作
更多操作可以在上面累加,比较容易
package mydatabase;import java.sql.*;public class MySql {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;public void setDburl(String dburl){this.dburl = dburl;}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 进行插入操作。
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");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 对应,否则会出现异常,导致执行插入命令失败
结果演示:
这是程序结果
你可以很容易地想到,用一个循环就可以实现一次性插入多条记录。
mysql 结果
插入成功!