在一些web開發或者是數據存儲的時候,肯定會使用到資料庫來進行數據存儲。而在Java裡面需要調用JDBC來對資料庫進行操作。每次用jdbc很麻煩,就可以採用一些連接池來解決這個問題 ...
0x00前言
在一些web開發或者是數據存儲的時候,肯定會使用到資料庫來進行數據存儲。而在Java裡面需要調用JDBC來對資料庫進行操作。每次用jdbc很麻煩,就可以採用一些連接池來解決這個問題
0x01常用類和方法
0x1Connection介面
1.createStatement()
創建一個 Statement對象,用於將SQL語句發送到資料庫。
2.close()
Connection發佈此 Connection對象的資料庫和JDBC資源,而不是等待它們自動釋放。
3.CallableStatement prepareCall(String sql)
創建一個調用資料庫存儲過程的 CallableStatement對象。
4.prepareStatement(String sql)
創建一個 PreparedStatement對象,用於將參數化的SQL語句發送到資料庫。 對sql語句進行預處理,解決sql註入問題
5.boolen execute(String sql)
執行的select語句就返回true,其他返回false
6.ResultSet executeQuery(String sql)
執行給定的(select)SQL語句,該語句返回單個 ResultSet對象,
7.int executeUpdate(String sql)
執行給定的SQL語句,這可能是 INSERT , UPDATE ,或 DELETE語句,或者不返回任何內容,如SQL DDL語句的SQL語句。返回的int是影響的函數
8.批處理的執行
(1)void addBatch(String sql)
將給定的SQL命令添加到此 Statement對象的當前命令列表中。
(2)int[] executeBatch()
將一批命令提交到資料庫以執行,並且所有命令都執行成功,返回一個更新計數的數組。
(3)void clearBatch()
清空此 Statement對象的當前SQL命令列表。
0x2ResultSet
1.表示資料庫結果集的數據表,通常通過執行查詢資料庫的語句生成。
2.boolean next()是否還有下一行數據存在返回true
3.getString(String key);查找指定的列名的數據
public class JVAV_Test01 {
public static void main(String[] args) throws Exception {
Class.forName("com.mysql.cj.jdbc.Driver");
Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306", "root", "zhonglin");
//執行sql語句的對象
Statement statement = connection.createStatement();
String s=("select * from web_1.student;");
ResultSet resultSet = statement.executeQuery(s);
while (resultSet.next()){
System.out.println(resultSet.getString("name"));
System.out.println(resultSet.getString("id"));
}
statement.close();
resultSet.close();
}
}
0x02抽取工具類和用配置文件使用
0x1Properties類
在使用jdbc的時候會存在很多重覆利用的代碼我們就可以把重覆的代碼給寫成一個類供我們使用,同時使用配置文件去靈活的配置資料庫文件。
0x2常用方法
1.String getProperty(String key)
使用此屬性列表中指定的鍵搜索屬性
2.void list(PrintStream out)
將此屬性列表列印到指定的輸出流。
public class Jdbc_toll_class {
private static final String drvierClassname;
private static final String user;
private static final String password;
private static final String url;
static {
Properties properties=new Properties();//專門處理配置文件的一個類
try {
properties.load(new FileInputStream("C:\\Users\\**\\IdeaProjects\\sec_Reptile\\src\\main\\resources\\db.properties"));//讀取配置文件路徑
} catch (IOException e) {
e.printStackTrace();
}
drvierClassname=properties.getProperty("drvierClassname");
user=properties.getProperty("user");
password=properties.getProperty("password");;
url=properties.getProperty("url");;
}
public static void loadDriver(){
try {
Class.forName(drvierClassname);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
public static Connection getConnecton() {
Connection connection = null;
try {
loadDriver();
connection = DriverManager.getConnection(url, user, password);
} catch (SQLException e) {
e.printStackTrace();
}return connection;
}
public static void release(Statement statement,Connection connection){
try {
connection.close();
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
public static void release(ResultSet resultSet, Statement statement, Connection connection){
try {
resultSet.close();
statement.close();
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
0x03public interface PreparedStatement
0x1方法基礎使用
1.int executeUpdate()
執行在該SQL語句PreparedStatement對象,它必須是一個SQL數據操縱語言(DML)語句,如INSERT , UPDATE或DELETE ; 或不返回任何內容的SQL語句,例如DDL語句。
2.boolean execute()
執行此 PreparedStatement對象中的SQL語句,這可能是任何類型的SQL語句。
3.ResultSet executeQuery()
執行此 PreparedStatement對象中的SQL查詢,並返回查詢 PreparedStatement的 ResultSet對象。
4.void setInt(String,byte)(int parameterIndex, int x)
將指定的參數設置為給定的Java int(String,byte)值。
public class JAVA_test03 {
public static void main(String[] args) {
Connection connection;
PreparedStatement preparedStatement;
connection=Jdbc_toll_class.getConnection();
String sql="insert into student values (null ,?)";
try {
preparedStatement=connection.prepareStatement(sql);
preparedStatement.setString(1,"hellow");
preparedStatement.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}
}
0x04批處理
1.首先要在的資料庫後面加上:?rewriteBatchedStatements=true
2.PreparedStatement的批處理是利用設置參數和循壞去處理
3.如果批處理命令過多要執行後清除再添加
public class JAVA_tese06 {
//批處理後面要加需要在連接的資料庫後面加上:?rewriteBatchedStatements=true
public static void main(String[] args) {
Connection connection = Jdbc_toll_class.getConnection();
PreparedStatement preparedStatement=null;
Jdbc_toll_class.executesql("use tese");
String sql="insert into user values(null,?)";
try {
preparedStatement = connection.prepareStatement(sql);
} catch (SQLException e) {
e.printStackTrace();
}
try {
for (int i = 0; i < 10; i++) {
preparedStatement.setString(1,"試試");
preparedStatement.addBatch();
if (i %10==0){
preparedStatement.execute();
preparedStatement.clearBatch();
}
}
}catch (Exception e){
e.printStackTrace();
}finally {
Jdbc_toll_class.release(connection,preparedStatement);
}
}
}
4.Statement批處理
5.是用addbatch,方法去把批處理命令都添加進去,用executeBatch執行
public class JAVA_test05 {
public static void main(String[] args) {
Connection connection = Jdbc_toll_class.getConnection();
try {
Statement statement = connection.createStatement();
String sql2="use tese";
String sql4="insert into user values(null,'aaa')";
String sql5="insert into user values(null,'bbb')";
String sql6="insert into user values(null,'ccc')";
String sql7="update user set name='mmm' where id=2";
String sql8="delete from user where id=1";
statement.addBatch(sql2);
statement.addBatch(sql4);
statement.addBatch(sql5);
statement.addBatch(sql6);
statement.addBatch(sql7);
statement.addBatch(sql8);
statement.executeBatch();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
0x05連接池
0x1c3p0連接池
public class c3p0_test {
1.獲取對象2.還是通過連接對象connection去獲取prepareStatement等對象去執行3.它的配置文件需要放在src下麵。
public static void main(String[] args) throws SQLException {
DataSource dataSource=new ComboPooledDataSource();//這裡可以選擇你的配置文件裡面預先設定好的配置
Connection connection = dataSource.getConnection();
System.out.println(connection);
}
0x2druid連接池
1.獲取對象是通過Properties類獲取文件
2.InputStream resourceAsStream = Druid_test.class.getClassLoader().getResourceAsStream("druid.properties");
3.properties.load(resourceAsStream);//構建配置文件
public class Druid_test {
public static void main(String[] args) {
Properties properties=new Properties();
InputStream resourceAsStream = Druid_test.class.getClassLoader().getResourceAsStream("druid.properties");
try {
properties.load(resourceAsStream);
DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
Connection connection = dataSource.getConnection();
System.out.println(connection);
} catch (IOException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}
}
4.工具類的定義
1.封裝一些方法方便我們使用方法
public class JDBCUtils {
//1定義成員變數
private static DataSource dataSource;
static {
try {
Properties properties=new Properties();
properties.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));
dataSource= DruidDataSourceFactory.createDataSource(properties);
} catch (IOException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}public static Connection getconnection() throws SQLException {
return dataSource.getConnection();
}
public static void close(Statement statement,Connection connection){
if (statement!=null){
try {
statement.close();
}catch (Exception E){
E.printStackTrace();
}
}
if (connection!=null){
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
public static void close(ResultSet resultSet, Statement statement, Connection connection){
if (statement!=null){
try {
statement.close();
}catch (Exception E){
E.printStackTrace();
}
}
if (connection!=null){
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (resultSet!=null){
try {
resultSet.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
public static DataSource getDataSource(){
return dataSource;
}
}
0x3JDBCtemplate
1.用Spring框架集成的這個JDBCtemplate,只需要獲取一個Source對象就可以直接執行sql語句
2。它會自己獲取連接對象和釋放連接對象,
public class JDBCtemplate {
public static void main(String[] args) {
JdbcTemplate jdbcTemplate = new JdbcTemplate(JDBCUtils.getDataSource());
String sql="insert into user values (null,?)";
int i = jdbcTemplate.update(sql, "小天");
System.out.println(1);
}
0x06總結
總結下來其實Spring框架的JDBCtemplate使用起來最簡單,以後在有框架開發的時候會用到這些,開發的時候多使用 preparedStatement,預防,sql註入。