一.前言
写这个文章的原因是为了巩固自己连接数据库步骤
二.MySQL数据库连接
数据库连接步骤加载驱动程序,获取数据库连接对象
2.1驱动jar包
2.2代码
package cn.sg.xx.test; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class Main { public static void main(String[] args) throws SQLException, ClassNotFoundException { try { //数据库驱动参数 String Driver = "com.mysql.cj.jdbc.Driver";//"com.mysql.jdbc.Driver"-->驱动地址已经过时 //连接的URL,数据库名为test String URL = "jdbc:mysql://localhost:3306/test?serverTimezone=UTC&characterEncoding=utf8";//后边的参数serverTimezone-->指定时区,characterEncoding-->编码格式 //数据库用户名 String Username = "root"; //数据库密码 String Password = "123"; //加载MySQL驱动程序 Class.forName(Driver); //与MySQL数据库创立连接 Connection con = null; con = DriverManager.getConnection(URL, Username, Password); } catch (ClassNotFoundException e) { System.out.println("驱动程序没有找到!"); } catch (SQLException e) { System.out.println("SQL异常!"); } } }
三.增加表数据
String sql = "INSERT INTO test(id,NAME,sex) VALUES(?,?,?);";
建议写成这种语法,指定插入的列,可以防止表字段修改后,程序报错
使用PreparedStatement 进行sql语句的装配,可以防止sql注入
3.1代码
package cn.sg.xx.test; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; public class Main { public static void main(String[] args) { try { //数据库驱动参数 String Driver = "com.mysql.cj.jdbc.Driver";//"com.mysql.jdbc.Driver"-->驱动地址已经过时 //连接的URL,数据库名为test String URL = "jdbc:mysql://localhost:3306/test?serverTimezone=UTC&characterEncoding=utf8";//后边的参数serverTimezone-->指定时区,characterEncoding-->编码格式 //数据库用户名 String Username = "root"; //数据库密码 String Password = "123"; //加载MySQL驱动程序 Class.forName(Driver); //与MySQL数据库创立连接 Connection con = null; con = DriverManager.getConnection(URL, Username, Password); //sql语句装配,?为占位符 String sql = "INSERT INTO test(id,NAME,sex) VALUES(?,?,?);"; PreparedStatement stmt = con.prepareStatement(sql); stmt.setInt(1, 2); stmt.setString(2, "张三"); stmt.setString(3, "男"); stmt.executeUpdate(); //执行完数据库的操作有指令之后要释放资源,否则会导致内存的溢出 stmt.close(); con.close(); } catch (ClassNotFoundException e) { System.out.println("驱动程序没有找到!"); } catch (SQLException e) { System.out.println("SQL异常!"); } } }
四.删除表数据
删除表数据的操作和插入操作基本相同,只有sql语句不同
4.1代码
String sql = "DELETE FROM test WHERE id = 1"; PreparedStatement stmt = con.prepareStatement(sql); stmt.executeUpdate();
五.修改表数据
同插入数据一样,仅仅修改sql语句为
六.查找表数据
表数据的查找需要比上边的插入、删除操作多关闭ResoultSet资源
ResoultSet rs;
rs.close();
6.1代码
//查找表数据 String sql = "SELECT * FROM test"; PreparedStatement stmt = con.prepareStatement(sql); ResultSet rs = stmt.executeQuery(); //从 rs 获取数据 while (rs.next()) { //rs.getMetaData().getColumnCount() --> 获取表的列数 for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++) { String colunmName = rs.getMetaData().getColumnName(i);//获取列名 Object temp = rs.getString(i);//获取该列对应元素的值 System.out.print(colunmName + "-->" + temp + "\t"); } System.out.println();
七.全部代码
package cn.sg.xx.test; import java.sql.*; public class Main { public static void main(String[] args) throws SQLException { Connection con = null; PreparedStatement stmt = null; ResultSet rs = null; try { //数据库驱动参数 String Driver = "com.mysql.cj.jdbc.Driver";//"com.mysql.jdbc.Driver"-->驱动地址已经过时 //连接的URL,数据库名为test String URL = "jdbc:mysql://localhost:3306/test?serverTimezone=UTC&characterEncoding=utf8";//后边的参数serverTimezone-->指定时区,characterEncoding-->编码格式 //数据库用户名 String Username = "root"; //数据库密码 String Password = "123"; //加载MySQL驱动程序 Class.forName(Driver); //与MySQL数据库创立连接 con = DriverManager.getConnection(URL, Username, Password); //sql语句装配,?为占位符 String sql = "INSERT INTO test(id,NAME,sex) VALUES(?,?,?);"; stmt = con.prepareStatement(sql); stmt.setInt(1, 2); stmt.setString(2, "张三"); stmt.setString(3, "男"); stmt.executeUpdate(); //删除表数据 sql = "DELETE FROM test WHERE id = 1"; stmt = con.prepareStatement(sql); stmt.executeUpdate(); //修改表数据 sql = "UPDATE test SET sex = '女' WHERE id = 1"; stmt = con.prepareStatement(sql); stmt.executeUpdate(); //查找表数据 sql = "SELECT * FROM test"; stmt = con.prepareStatement(sql); rs = stmt.executeQuery(); //从 rs 获取数据 while (rs.next()) { //rs.getMetaData().getColumnCount() --> 获取表的列数 for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++) { String colunmName = rs.getMetaData().getColumnName(i);//获取列名 Object temp = rs.getString(i);//获取该列对应元素的值 System.out.print(colunmName + "-->" + temp + "\t"); } System.out.println(); } //执行完数据库的操作有指令之后要释放资源,否则会导致内存的溢出 } catch (ClassNotFoundException e) { System.out.println("驱动程序没有找到!"); } catch (SQLException e) { System.out.println("SQL异常!"); } finally { //关闭资源 if (rs != null) rs.close(); if (stmt != null) stmt.close(); if (con != null) con.close(); } } }
最后给大家推荐一个口碑不错的Java聚集地【点击进入】,这里有很多的老前辈学习技巧,学习心得,面试技巧,职场经历等分享,更为大家精心准备了零基础入门资料,实战项目资料,每天都有程序员定时讲解java技术,分享一些学习的方法和需要留意的小细节。