ベースJDBC API使用
ベースJDBC API使用基本フロー 保存動作 変更操作削除操作 基本プロセス
保存アクション
変更操作削除操作
基本的な類似はsql文を変更するだけでよい
import com.mysql.jdbc.Driver;
import org.junit.Test;
import java.sql.*;
public class Demo1 {
@Test
public void demo1() {
// , try
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
//1.
try {
//DriverManager.registerDriver(new Driver());
//
// Class.forName()
Class.forName("com.mysql.cj.jdbc.Driver");
//2.
conn = DriverManager.getConnection("jdbc:mysql:///jdbctest", "root", "root");
// DriverManager
//Connection sql
//Statement createStatement/ ===> sql ( sql )
//PreparedStatement prepareStatement(String sql) ===> sql
//CallableStatement prepareCall(String sql) ===> sql
//
//setAutoCommit(boolean autoCommit) ===>
//commit() ===>
//rollback() ===>
//3.
String sql = "select * from user";
stmt = conn.createStatement();
//Statement
//boolean execute(String sql) ===> sql( select true/ false)
//ResultSet executeQuery(String sql) ===>sql select
//int executeUpdate(String sql) ===>sql insert/update/delete
//
//addBatch(String sql) ===>
//executeBatch() ===>
//clearBatch() ===>
rs = stmt.executeQuery(sql);
// ( )
//next()
// getString...
// getObject
while (rs.next()) {
int uid = rs.getInt("uid");
String username = rs.getString("username");
String password = rs.getString("password");
String name = rs.getString("name");
System.out.println(uid + "" + username + " " + password + " " + name);
}
//4.
//rs.close();
//stmt.close();
//conn.close();
//connection ,
// final
} catch (SQLException | ClassNotFoundException e) {
e.printStackTrace();
} finally {
//
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
rs = null;
//
}
if (stmt != null) {
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
stmt = null;
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
conn = null;
}
}
}
保存アクション
public class Demo2 {
@Test
public void demo1() {
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
try {
Class.forName("com.mysql.cj.jdbc.Driver");
conn = DriverManager.getConnection("jdbc:mysql:///jdbctest","root","root");
stmt = conn.createStatement();
String sql = "insert into user values(null,'eee','123',' ')";
int i = stmt.executeUpdate(sql);
if(i>0){
System.out.println("success");
}
} catch (Exception e) {
e.printStackTrace();
} finally {
if (stmt != null) {
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
stmt = null;
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
conn = null;
}
}
}
}
変更操作削除操作
基本的な類似はsql文を変更するだけでよい
String sql = "update user set username = 'qqq',password = '423', name =' ' where uid = 4";
String sql = "delete from user where uid = 4";