您好,登錄后才能下訂單哦!
今天小編給大家分享一下Java怎么連接MySQL數(shù)據(jù)庫的相關(guān)知識(shí)點(diǎn),內(nèi)容詳細(xì),邏輯清晰,相信大部分人都還太了解這方面的知識(shí),所以分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后有所收獲,下面我們一起來了解一下吧。
首先說明,由于是8版本的數(shù)據(jù)庫,所以配置類的寫法上與5版本的有所區(qū)別,需要注意,同時(shí)用idea或eclipse時(shí)需要導(dǎo)入jar包
如果想要下載8版本不同的jar包只需要修改8.0.28為指定版本即可。
idea導(dǎo)入jar包的方法如下:
然后是代碼部分,首先先建表:
CREATE TABLE `train_message` ( `id` int NOT NULL AUTO_INCREMENT COMMENT '主鍵id', `train_name` varchar(20) NOT NULL COMMENT '列車名', `origin` varchar(30) NOT NULL COMMENT '始發(fā)地', `terminal` varchar(30) NOT NULL COMMENT '終到地', `departure_time` timestamp NOT NULL COMMENT '出站時(shí)間', `state` varchar(10) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL DEFAULT '正常' COMMENT '列車狀態(tài)', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=9 DEFAULT CHARSET=utf8mb3
然后創(chuàng)建連接的配置類DbConfig.java,localhost是本機(jī)的ip地址,如果有服務(wù)器就填服務(wù)器的ip地址,message是數(shù)據(jù)庫的名字,這里一張圖說下有很多新手誤解的名字
import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; /** * 數(shù)據(jù)庫配置類 * @author 景苒 */ public class DbConfig { public Connection dbConfig() throws SQLException { try { Class.forName("com.mysql.cj.jdbc.Driver"); }catch (Exception e) { System.out.print("加載驅(qū)動(dòng)失敗!"); e.printStackTrace(); } String url = "jdbc:mysql://localhost:3306/message?useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT%2B8&allowPublicKeyRetrieval=true"; String user = "root"; String password = "123456"; return DriverManager.getConnection(url, user, password); } }
然后寫下主函數(shù)Main.java,這里主函數(shù)的函數(shù)體可以在最后再寫,需要什么功能就把注釋打開就好,快捷注釋的方法,選中這句話,按ctrl加/,就能全注釋了。
import java.sql.SQLException; /** * 主函數(shù),調(diào)用功能 * @author 景苒 */ public class Main { public static void main(String[] args) throws SQLException { // new GetMessage().getMessage(); // new UpdateTrainState().updateTrainState(); // new InsertTrain().insertTrain(); // new GetNumber().getNumber(); } }
然后是每個(gè)的功能:
建GetMessage.java類
import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; /** * 查詢沈陽到武漢的所有列車信息,按出發(fā)時(shí)間先后排序 * @author 景苒 */ public class GetMessage { public void getMessage() throws SQLException { Connection con = new DbConfig().dbConfig(); String sql = "select * from `train_message` where origin = ? and terminal = ? ORDER BY departure_time ASC"; String origin = "沈陽"; String terminal = "武漢"; PreparedStatement ps = con.prepareStatement(sql); ps.setString(1, origin); ps.setString(2, terminal); ResultSet rs = ps.executeQuery(); try { while (rs.next()) { System.out.println("列車名:" + rs.getString("train_name") + " 始發(fā)站:" + rs.getString("origin") + " 終到站:" + rs.getString("terminal") + " 出發(fā)時(shí)間:" + rs.getString("departure_time") + " 列車狀態(tài):" + rs.getString("state")); } }catch (SQLException e) { e.printStackTrace(); }finally { ps.close(); con.close(); } } }
建UpdateTrainState.java類
import java.sql.Connection; import java.sql.SQLException; import java.sql.Statement; /** * 修改T2255列車的狀態(tài)為停運(yùn) * @author 景苒 */ public class UpdateTrainState { public void updateTrainState() throws SQLException { Connection con = new DbConfig().dbConfig(); String sql = "UPDATE `train_message` SET state = '停運(yùn)' WHERE train_name = 'T2255'"; Statement statement = con.createStatement(); try { int i = statement.executeUpdate(sql); if (i > 0) { System.out.println("更新成功"); }else { System.out.println("更新失敗"); } }catch (SQLException e) { e.printStackTrace(); }finally { statement.close(); con.close(); } } }
建InsertTrain.java類
import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import java.util.Scanner; /** * 新增一輛列車信息(自己輸入) * 始發(fā)時(shí)間為timestamp類型,輸入時(shí)需要確保格式正確,如:2019-01-01 00:00:00 * @author 景苒 */ public class InsertTrain { public void insertTrain() throws SQLException { Connection con = new DbConfig().dbConfig(); Scanner scanner = new Scanner(System.in); String sql = "insert into `train_message` values(null, ?, ?, ?, ?, default)"; System.out.print("請輸入列車名:"); String trainName = scanner.nextLine(); System.out.print("請輸入始發(fā)站:"); String origin = scanner.nextLine(); System.out.print("請輸入終到站:"); String terminal = scanner.nextLine(); System.out.print("請輸入始發(fā)時(shí)間:"); String departureTime = scanner.nextLine(); PreparedStatement ps = con.prepareStatement(sql); ps.setString(1, trainName); ps.setString(2, origin); ps.setString(3, terminal); ps.setString(4, departureTime); try { int i = ps.executeUpdate(); if (i > 0) { System.out.println("添加成功"); }else { System.out.println("添加失敗"); } }catch (SQLException e) { e.printStackTrace(); }finally { ps.close(); con.close(); } } }
建GetNumber.java類
import java.sql.Statement; /** * 查詢狀態(tài)為正常的列車數(shù)量 * @author 景苒 */ public class GetNumber { public void getNumber() throws SQLException { Connection con = new DbConfig().dbConfig(); String sql = "select count(state) from `train_message` where state = '正常'"; Statement statement = con.createStatement(); try { ResultSet resultSet = statement.executeQuery(sql); while (resultSet.next()) { System.out.println("狀態(tài)為正常的列車數(shù)量為:" + resultSet.getInt(1)); } }catch (SQLException e){ e.printStackTrace(); }finally { statement.close(); con.close(); } } }
最后附上navicat的屬性結(jié)構(gòu)圖和樣例插入的語句
數(shù)據(jù)根據(jù)自己需求自行寫入幾個(gè)就行,以上就是java連接mysql數(shù)據(jù)庫的實(shí)例代碼,eclipse也大同小異,就導(dǎo)入jar包的方式不同。
以上就是“Java怎么連接MySQL數(shù)據(jù)庫”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家閱讀完這篇文章都有很大的收獲,小編每天都會(huì)為大家更新不同的知識(shí),如果還想學(xué)習(xí)更多的知識(shí),請關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。