在Java中基于mysql驱动包连接MySQL数据库

MySQL驱动包

Java程序要连接MySQL数据库&＃xff0c;需要使用MySQL驱动包&＃xff08;jar包&＃xff09;&＃xff0c;当前驱动包的最新版本是&＃xff1a;mysql-connector-java-8.0.21.zip。解压这个压缩包&＃xff0c;会看到如下的文件夹结构&＃xff0c;其中的mysql-connector-java-8.0.21.jar就是我们需要的MySQL驱动包。把这个jar包复制到Java项目的用于存储库文件的libs文件夹中&＃xff0c;再在IDE里导入这个jar包&＃xff0c;如此就可以使用jar包里的API了。

代码示例

mysql-connector在8.0之前和之后的jar包是不同的&＃xff0c;在使用时会一定的区别。在进行如下操作前&＃xff1a;需保证已安装了MySQL数据库&＃xff0c;并打开了MySQL数据服务器&＃xff08;启动服务器&＃xff1a;“net start mysql”&＃xff0c;停止服务器&＃xff1a;“net stop mysql”&＃xff09;&＃xff0c;其次&＃xff0c;还需保证创建了数据库&＃xff08;可通过附录中的mysql.sql数据库脚本来创建数据库&＃xff0c;并插入相应的数据&＃xff09;。

1、连接数据库需要四个信息&＃xff1a;驱动名、数据库url、用户名和密码&＃xff0c;一般被声明为静态常量。

// mysql-connector 8.0版本之前-JDBC驱动名及数据库URL&＃xff08;8.0之前和之后的区别就在于驱动名和URL这两项上&＃xff09;static final String JDBC_DRIVER &＃61; "com.mysql.jdbc.Driver"; // JDBC驱动名static final String DB_URL &＃61; "jdbc:mysql://localhost:3306/auction"; // 数据库URL// mysql-connector 8.0版本之后-JDBC驱动名及数据库URL//static final String JDBC_DRIVER &＃61; "com.mysql.cj.jdbc.Driver";// 8.0版本之后必须要在数据库URL中添加上服务器时区参数&＃xff0c;否则会出错//static final String DB_URL &＃61; "jdbc:mysql://localhost:3306/auction?serverTimezone&＃61;UTC";//一般情况下&＃xff0c;会在数据库URL中添加上如下的参数//final static String url &＃61; "jdbc:mysql://localhost:3306/myblog?useUnicode&＃61;true&characterEncoding&＃61;UTF-8&zeroDateTimeBehavior&＃61;convertToNull&useSSL&＃61;false&serverTimezone&＃61;UTC&allowPublicKeyRetrieval&＃61;true";// 数据库的用户名与密码&＃xff0c;需要根据自己的设置static final String USER &＃61; "root"; // 数据库用户名static final String PASS &＃61; "123456"; // 用户密码


2、对数据库操作一般分为如下的三个步骤&＃xff1a;
a、注册驱动和连接数据库

// 注册JDBC驱动Class.forName(JDBC_DRIVER);// 打开链接System.out.println("连接数据库...");Connection conn &＃61; DriverManager.getConnection(DB_URL,USER,PASS);


b、进行增删改查等数据操作

// 执行查询System.out.println(" 实例化Statement对象...");Statement stmt &＃61; conn.createStatement();String sql;sql &＃61; "SELECT user_id, username, userpass, email FROM auction_user";ResultSet rs &＃61; stmt.executeQuery(sql);// 打印从数据库中查询返回的结果集while(rs.next()){// 通过字段检索int user_id &＃61; rs.getInt("user_id");String username &＃61; rs.getString("username");String userpass &＃61; rs.getString("userpass");String email &＃61; rs.getString("email");// 打印数据System.out.print("用户ID: " &＃43; user_id);System.out.print(", 用户名称: " &＃43; username);System.out.print(", 用户密码: " &＃43; userpass);System.out.print(", 邮箱: " &＃43; email);System.out.print("\n");}


c、按顺序关闭资源

rs.close(); // 结果集stmt.close(); // 语句conn.close(); // 数据库连接


附录

mysql.sql脚本的使用方式&＃xff1a;&＃xff08;1&＃xff09;登录进MySQL数据库&＃xff08;在cmd中输入命令“mysql -u username -p”&＃xff0c;按回车&＃xff0c;待提示输入密码时&＃xff0c;再输入用户密码&＃xff09;&＃xff0c;&＃xff08;2&＃xff09;执行mysql脚本&＃xff08;source ***/mysql.sql&＃xff09;。

脚本文件&＃xff1a;mysql.sql

drop database if exists auction;create database auction;use auction;#用户表
create table auction_user(user_id int(11) auto_increment,username varchar(50) not null,userpass varchar(50) not null,email varchar(100) not null,primary key(user_id),unique(username)
);INSERT INTO auction_user (username,userpass,email) VALUES (&＃39;tomcat&＃39;,&＃39;tomcat&＃39;,&＃39;spring_test&＃64;163.com&＃39;);
INSERT INTO auction_user (username,userpass,email) VALUES (&＃39;mysql&＃39;,&＃39;mysql&＃39;,&＃39;spring_test&＃64;163.com&＃39;);#物品种类表
create table kind(kind_id int(11) auto_increment,kind_name varchar(50) not null, kind_desc varchar(255) not null,primary key(kind_id)
);INSERT INTO kind (kind_name,kind_desc) VALUES (&＃39;电脑硬件&＃39;,&＃39;这里并不是很主流的产品&＃xff0c;但价格绝对令你心动&＃39;);
INSERT INTO kind (kind_name,kind_desc) VALUES (&＃39;房产&＃39;,&＃39;提供非常稀缺的房源&＃39;);#物品状态表
create table state(state_id int(11) auto_increment,state_name varchar(10),primary key(state_id)
);INSERT INTO state (state_name) VALUES (&＃39;拍卖中&＃39;);
INSERT INTO state (state_name) VALUES (&＃39;拍卖成功&＃39;);
INSERT INTO state (state_name) VALUES (&＃39;流拍&＃39;);#物品表
create table item(item_id int(11) auto_increment,item_name varchar(255) not null,item_remark varchar(255),item_desc varchar(255),kind_id int(11) not null, addtime date not null,endtime date not null,init_price double not null, max_price double not null, owner_id int(11) not null, winer_id int(11), state_id int(11) not null, primary key(item_id),FOREIGN KEY(kind_id) REFERENCES kind(kind_id), FOREIGN KEY(owner_id) REFERENCES auction_user(user_id),FOREIGN KEY(winer_id) REFERENCES auction_user(user_id),FOREIGN KEY(state_id) REFERENCES state(state_id)
); # 拍卖中的物品
INSERT INTO item ( item_name , item_remark , item_desc, kind_id, addtime , endtime, init_price, max_price, owner_id, winer_id, state_id)VALUES ( &＃39;主板&＃39;, &＃39;老式主板&＃39;, &＃39;老主板&＃xff0c;还可以用&＃39;, 1, ADDDATE(CURDATE(), -5), ADDDATE(CURDATE(), 30) , 230, 250, 1, null, 1);
# 流派的物品
INSERT INTO item ( item_name , item_remark , item_desc, kind_id, addtime , endtime, init_price, max_price, owner_id, winer_id, state_id)VALUES ( &＃39;显卡&＃39;, &＃39;老式显卡&＃39;, &＃39;老显卡&＃xff0c;还可以用&＃39;, 1, ADDDATE(CURDATE(), -9), ADDDATE(CURDATE(), -2), 210, 210, 2, null, 3);
# 被竞得的物品
INSERT INTO item ( item_name , item_remark , item_desc, kind_id, addtime , endtime, init_price, max_price, owner_id, winer_id, state_id)VALUES ( &＃39;老房子&＃39;, &＃39;老式房子&＃39;, &＃39;40年的老房子&＃39;, 2, ADDDATE(CURDATE(), -9), ADDDATE(CURDATE(), -5), 21000, 25000, 2, 1, 2);#竞标历史表
create table bid(bid_id int(11) auto_increment,user_id int(11) not null,item_id int(11) not null,bid_price double not null,bid_date date not null, primary key(bid_id),unique(item_id , bid_price),FOREIGN KEY(user_id) REFERENCES auction_user(user_id), FOREIGN KEY(item_id) REFERENCES item(item_id)
);INSERT INTO bid ( user_id , item_id , bid_price, bid_date)VALUES ( 2, 1, 250, ADDDATE(CURDATE(), -2));
INSERT INTO bid ( user_id , item_id , bid_price, bid_date)VALUES ( 1, 3, 25000, ADDDATE(CURDATE(), -6));