jdbc使用的是8.0.11版本.
import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.prefs.Preferences; import org.testng.annotations.Test; import com.mysql.cj.protocol.Resultset; public class T1 { public static final String URL = "jdbc:mysql://localhost:3306/jdbctest?characterEncoding=utf8&useSSL=true&serverTimezone=GMT"; public static final String USER = "root"; public static final String PASSWORD = "111111"; private static Connection conn = null; public static void main(String[] args) { T1 t = new T1(); t.connectMySQLSelect3(); } // 增 public void connectMySQLInsert() { try { String sql = "insert into student values(?,?)"; Class.forName("com.mysql.cj.jdbc.Driver"); conn = DriverManager.getConnection(URL, USER, PASSWORD); System.out.println("连接成功!"); PreparedStatement ps = conn.prepareStatement(sql); // 从1开始 不是0 ps.setInt(1, 6); ps.setString(2, "赵七"); ps.execute(); conn.close(); } catch (SQLException | ClassNotFoundException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } // 删 public void connectMySQLDelete() { try { String sql = "delete from student where id=?"; Class.forName("com.mysql.cj.jdbc.Driver"); conn = DriverManager.getConnection(URL, USER, PASSWORD); System.out.println("连接成功!"); PreparedStatement ps = conn.prepareStatement(sql); // 从1开始 不是0 ps.setInt(1, 6); ps.execute(); conn.close(); } catch (SQLException | ClassNotFoundException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } // 改 public void connectMySQLUpdate() { try { String sql = "update student set name =? where id =?"; Class.forName("com.mysql.cj.jdbc.Driver"); conn = DriverManager.getConnection(URL, USER, PASSWORD); System.out.println("连接成功!"); PreparedStatement ps = conn.prepareStatement(sql); // 从1开始 不是0 ps.setString(1, "赵七"); ps.setInt(2, 5); ps.execute(); conn.close(); } catch (SQLException | ClassNotFoundException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } // 查 @Test public void connectMySQLSelect1() { try { String sql = "select * from student where id =?"; Class.forName("com.mysql.cj.jdbc.Driver"); conn = DriverManager.getConnection(URL, USER, PASSWORD); System.out.println("连接成功!"); PreparedStatement ps = conn.prepareStatement(sql); ps.setInt(1, 2); ps.execute(); ResultSet res = ps.executeQuery(); while (res.next()) { System.out.println("id: " + res.getInt(1) + " name: " + res.getString("name")); } conn.close(); } catch (SQLException | ClassNotFoundException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } public void connectMySQLSelect2() { try { String sql = "select * from student"; Class.forName("com.mysql.cj.jdbc.Driver"); conn = DriverManager.getConnection(URL, USER, PASSWORD); System.out.println("连接成功!"); PreparedStatement ps = conn.prepareStatement(sql); ps.execute(); ResultSet res = ps.executeQuery(); while (res.next()) { System.out.println("id: " + res.getInt(1) + " name: " + res.getString("name")); } conn.close(); } catch (SQLException | ClassNotFoundException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } // 查3 public void connectMySQLSelect3() { try { String sql = "select * from student"; Class.forName("com.mysql.cj.jdbc.Driver"); conn = DriverManager.getConnection(URL, USER, PASSWORD); System.out.println("连接成功!"); Statement ps = conn.createStatement(); ResultSet rs = ps.executeQuery(sql); while (rs.next()) { System.out.println("id: " + rs.getInt("id") + " name: " + rs.getString(2)); } conn.close(); } catch (ClassNotFoundException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } catch (SQLException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } }
还没有评论,来说两句吧...