資料庫基本操作框架(自用)
阿新 • • 發佈:2018-11-08
1、首先新增mysql-connector的jar包
2、配置基本的jdbc資料
package Jdbcnn;
public interface JdbcConfig {
String DRIVER = "com.mysql.jdbc.Driver";
String URL = "jdbc:mysql://localhost:3306/ceshi";
String USERNAME = "root";
String PASSWORD = "root";
}
3、設定連線方法
package Jdbcnn; import java.sql.Connection; import java.sql.DriverManager; public class JdbcConn implements JdbcConfig { public Connection getConn(){ Connection conn = null; try { Class.forName(DRIVER); conn = DriverManager.getConnection(URL,USERNAME, PASSWORD); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } return conn; } }
4、增刪查改基本方法
package Jdbcnn; //要有jdbc的連線包 import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; public class JdbcHelp implements JdbcConfig { JdbcConn conns = new JdbcConn(); private Connection conn = conns.getConn(); private PreparedStatement ps= null; private ResultSet rs= null; //向student表中插入一個同學 public boolean insert(String sql) { // TODO Auto-generated method stub try { ps = conn.prepareStatement(sql); ps.setInt(1, 8); ps.setString(2,"A"); ps.setString(3, "女"); int a= ps.executeUpdate(); boolean flag =true; if(a!=1){ flag=false; } return flag; } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return false; } //刪除 public void dele(String sql) { // TODO Auto-generated method stub try { ps=conn.prepareStatement(sql); /** * 如果使用execute()刪除成功也返回false * 如果使用executeUpdate(),刪除成功返回1 刪除失敗返回0 */ int flag = ps.executeUpdate(); System.out.println(flag); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } //更新 public int updata(String sql) { // TODO Auto-generated method stub try { ps=conn.prepareStatement(sql); int flag =ps.executeUpdate(); System.out.println(flag); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return 0; } //查詢方法事例 public void search(String sql) { // TODO Auto-generated method stub try { ps=conn.prepareStatement(sql); rs=ps.executeQuery(); while(rs.next()){ String id = rs.getString(1); String name = rs.getString(2); String gender = rs.getString(3); System.out.println("id "+id+" name "+name+" gender "+gender); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } //測試方法 public static void main(String[] args) { JdbcHelp jh = new JdbcHelp(); //執行插入 String sql="insert into student(id,NAME,gender) values(?,?,?);"; //執行刪除 // String sql = "delete from student where id =1;"; //執行查詢 // String sql = "SELECT * from student"; String sql = "UPDATE student SET id =3 where id= 2"; jh.updata(sql); } }