2. 程式人生 > >Java連線資料庫DBHelper增刪改查[多條資料]

Java連線資料庫DBHelper增刪改查[多條資料]

阿新 • • 發佈：2019-01-27

補充！忘記寫思路了。。。
思路
1. 使用Class.forName()載入驅動
2. 驅動管理指定資料庫並連線 Connection conn = DriverManager.getConnection()
3. 連線後，使用連接獲取預處理(處理sql語句) PreparedStatement pst = conn.preparedStatement(“sql語句”)
4. 使用預處理執行相應操作得到一個結果集 ResultSet rs = pst.executeQuery();
5. 獲取元資料即資料庫中一部分資料 ResultSetMetaData rsd = rs.getMetaData();
6. rsd中則包含資料庫資訊一定要要判斷rsd.next() 是否有值，才能進一步操作
7. 根據資料庫欄位名獲取資料庫中相應的值 rs.getObject(“欄位名”); 8.最後關閉連線，預處理，結果集

上午一大早被吵醒…乾脆起來寫程式碼，於是就有了這個DBHelper工具類，算是複習複習。
在實際開發過程中沒有資料庫基本是不能活呀！改工具類寫了較詳細的註釋。
都是根據自己的理解寫的，如果不對之處歡迎提出！不勝感激。

檔案包括：
- jar包 oracle和mysql
- 一下描述到的類和配置檔案

檔案結構圖
這裡寫圖片描述

此類支援以下功能

  1. 增加
  2. 刪除
  3. 修改
  4. 查詢結果只有單條資料
  5. 查詢結果有多條資料
  6. 多條語句查詢

MyDbHelper類

package com.wy.mydb;

import java.io.IOException;
import java.sql.Connection;
import
 
 java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.wy.properties.MyProperties;

public class
 
 MyDbHelper {
    private  Connection conn = null;
    private  PreparedStatement ps = null;
    private  ResultSet rs = null;

    //載入驅動
    static {
        try {
            //方式一  固定寫死  不方便更改資料庫操作
//          Class.forName("com.mysql.jdbc.Driver"); //Oracle驅動為: oracle.jdbc.driver.OracleDriver
            //方式二  讀取配置檔案操作  如果需要更換資料庫只需要修改配置檔案即可   推薦
            try {
                Class.forName(MyProperties.getInstance().getProperty("driverName"));
            } catch (IOException e) {
                e.printStackTrace();
            }

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } 
    }


    //驅動管理連線指定資料庫  獲取連線物件
    public Connection getConnection() {

        try {
            //方式一   固定寫死  不方便更改資料庫操作
            //驅動管理指定資料庫並連線          引數說明  埠資訊  資料庫賬戶  密碼
//          conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "a");
            //方式二  讀取配置檔案操作  如果需要更換資料庫只需要修改配置檔案即可   推薦
            try {
                conn = DriverManager.getConnection(MyProperties.getInstance().getProperty("url"),MyProperties.getInstance());
            } catch (IOException e) {
                e.printStackTrace();
            }

        } catch (SQLException e) {
            e.printStackTrace();
        }
        return conn;
    }

    //關閉所有物件              連線                預處理                 結果集
    public void closeAll(Connection conn,PreparedStatement ps,ResultSet rs) {
        if(conn!=null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if(ps!=null) {
            try {
                ps.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if(rs!=null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }



    /**單條語句的增刪改   說明:在執行成功後函式返回的結果為非零整數
     * @param sql  需要執行的sql語句
     * @param params 執行sql語句的引數
     * @return
     */
    public int doUpdate(String sql,List<Object> params) {
        int result = 0;
        //獲取連線
        conn = getConnection();
        //預處理
        try {
            ps = conn.prepareStatement(sql);
            //設定引數得到結果集
            this.setParams(ps,params);
            //預處理執行得到結果反饋
            result = ps.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            //關閉所有物件
            this.closeAll(conn, ps, rs);
        }
        return result;
    }


    /**
     * 多條語句的增刪改     說明:這些語句要麼同時成功，要麼都失敗
     * @param sqls   多條sql語句
     * @param params 執行引數
     * @return
     */
    public int doUpdate(List<String> sqls,List<Object> params) {
        int result = 0;
        //獲取連線
        conn = getConnection();
        try {
            //多條語句的執行涉及到事務    設定事務提交方式為手動
            conn.setAutoCommit(false);
            //判斷sql語句集合
            if(sqls!=null&&sqls.size()>0) {
                //迴圈每一條語句執行
                for(int i=0;i<sqls.size();i++) {
                    ps = conn.prepareStatement(  sqls.get(i) );
                    //設定引數
                    ps.setObject(i+1, params.get(i));
                    //執行並反饋
                    result = ps.executeUpdate();
                }
            }
            //手動提交資料
            conn.commit();
        } catch (SQLException e) {
            //出現錯誤則回滾資料
            try {
                conn.rollback();
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
            e.printStackTrace();
        } finally {
            //回覆事務自動提交
            try {
                conn.setAutoCommit(true);
            } catch (SQLException e) {
                e.printStackTrace();
            }
            //關閉所有物件
            this.closeAll(conn, ps, rs);
        }   
        return result;
    }



    /**
     * 設定預處理的引數
     * @param ps      預處理
     * @param params 引數集合
     * @throws SQLException 
     */
    public void setParams(PreparedStatement ps,List<Object> params) throws SQLException {
        if(params!=null&&params.size()>0) {
            for(int i=0;i<params.size();i++) {
                ps.setObject(i+1, params.get(i));
            }
        }
    }


    /**
     * 查詢sql語句單條結果
     * @param sql   查詢的sql語句
     * @param params執行sql所需引數
     * @return
     */
    public Map<String,Object> findSingleObject(String sql,List<Object> params){
        Map<String,Object> map = new HashMap<String,Object>();
        //獲取連線
        conn = getConnection();
        //預處理
        try {
            ps = conn.prepareStatement(sql);
            //設定引數
            this.setParams(ps, params);
            //執行查詢得到結果集
            rs = ps.executeQuery();
            //獲取資料庫該表所有欄位名
            List<String> names = getAllColumnName(rs);
            if(rs.next()) {
                //迴圈names
                for(String name:names) {
                    map.put(name,  rs.getObject(name) );
                }
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //關閉物件
            this.closeAll(conn, ps, rs);
        }
        return map;
    }


    /**
     * 查詢sql語句多條結果
     * @param sql
     * @param params
     * @return
     */
    public List<Map<String,Object>> findMulitObject(String sql,List<Object> params){
        List<Map<String,Object>> list = new ArrayList<Map<String,Object>>();
        //連線
        conn = this.getConnection();
        //預處理
        try {
            ps = conn.prepareStatement(sql);
            //設定引數
            this.setParams(ps, params);
            //執行查詢得到結果集
            rs = ps.executeQuery();
            //獲取所有列名
            List<String> names = this.getAllColumnName(rs);
            while(rs.next()) { //注意這裡不能用if 因為使用if的話只能執行一次 最後得到的結果就成了查一條資料
                Map<String, Object> map = new HashMap<String,Object>();
                //迴圈迭代
                for(String name:names) {
                    map.put(name, rs.getObject(name));
                }
                list.add( map );
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return list;
    }



    /**
     * 根據結果集獲取資料庫中的所有列表名
     * @param rs
     * @return
     */
    private List<String> getAllColumnName(ResultSet rs) {
        List<String> names = new ArrayList<String>();
        try {
            ResultSetMetaData rsmd = rs.getMetaData();
            for(int i=0;i<rsmd.getColumnCount();i++) {
                names.add(   rsmd.getColumnName(i+1)  );
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return names;
    }

}

MyProperties類 說明:用於讀取配置檔案db.properties

package com.wy.properties;

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

/**
 * 整個類只需要建立一個物件
 * 設計成單例模式
 */
public class MyProperties extends Properties{

    private static MyProperties myProperties;

    private MyProperties() throws IOException{
        InputStream in = MyProperties.class.getClassLoader().getResourceAsStream("db.properties");
        try {
            this.load(in);
        } catch (IOException e) {       
            e.printStackTrace();
            throw e;
        }
    }

    public static MyProperties getInstance() throws IOException{
        if(null==myProperties){
            myProperties = new MyProperties();
        }
        return myProperties;
    }
}

db.properties 說明:輸入自己的資料庫連結密碼 注意 所有輸入後面不能有空格！ 那句英文我感覺有錯誤…寫英文的原因是，中文會被處理

#oracle
#driverName=oracle.jdbc.driver.OracleDriver
#url=jdbc:oracle:thin:@localhost:1521:orcl
#user=scott
#password=   please input your database password

#mysql  #please input your database password
driverName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/test
user=root
password=   please input your database password

資料庫檔案

create table student(
    sid int primary key auto_increment,
    sname varchar(10)
)

insert into student(sname) values('馬小跳')
insert into student(sname) values('淘氣包')

select * from student where sid = 2
delete from student where sid = 3

相關推薦

Java連線資料庫DBHelper增刪改查[多條資料]

補充！忘記寫思路了。。。 思路 1. 使用Class.forName()載入驅動 2. 驅動管理指定資料庫並連線 Connection conn = DriverManager.getConnection() 3. 連線後，使用連接獲取預處理(處理

mongodb--java連線資料庫實現增刪改查

1.新建一個maven專案，匯入 <dependencies>       <dependency>         <groupId>junit</grou

java通過JDBC連線資料庫及增刪改查操作

1.實戰資料庫資料的準備    建立資料庫（newsmanager），然後建立表news（id，title，content，type）和newstype（id，name），其中news的type和newstype的id為主外來鍵關係，如下圖圖   2.JDBC的介紹  

flask連線資料庫的增刪改查

flask日常步驟省略 增 1 #建立資料庫物件 2 db = SQLAlchemy(app) 3 4 #建立資料庫類，用來對映資料庫表,將資料庫的模型作為引數傳入 5 class User(db.Model): 6 #宣告表名 7 __tablename__ = '

類封裝版學生管理系統，連線資料庫，增刪改查，拿去用，不謝。

# coding = utf-8 import sqlite3 class Student(object): def __init__(self, id, name, age, sex, phone): self.id = id self.name

C# 連線資料庫實現增刪改查

class Program { private static string urls = "server=127.0.0.1;port=3306;user=root;password=123; database=abc;"; private MySqlConne

jmeter連線資料庫實現增刪改查

啟動jmeter,進入jmeter的bin目錄下,找到jmeter,雙擊啟動jmeter.bat檔案 網上下載jmeter連線資料庫jar包 新增資料庫連線jar包,測試計劃 不新增在這裡也可以,另一種方法是把jar直接放在jmeter-lib-ext目錄下 新增執行緒組,測

Java8下連線資料庫進行增刪改查(CRDU)操作

原始碼 步驟 1.獲取資料庫連線 此處直接用寫好的DBUtil操作，這裡檢視詳解 Connection conn = DBUtil.getConnection(); 2.建立會話，有兩種方式 1.使用Statement建立（因為有

使用c3p0連線資料庫實現增刪改查

學習spring之前，視訊中先給我們一個任務就是用c3p0連線資料庫來完成增刪改查一,、準備       JAR包：            既然是連線資料庫第一個最重要的就是資料庫的驅動包mysql-connection-java-5.1.44-bin.jar        

Java連線MySQL實現增刪改查

現在許多框架都對資料庫進行了封裝，但是我們剛開始學習時，更好的還是使用Java手寫sql語句，進行相關操作，以便於我們瞭解Mysql呼叫機制。 本文中我們實現使用者註冊的基礎操作：從jsp得到使用者

IDEA java連線mysql資料庫，實現對資料庫的增刪改查

先上程式碼： package Database_Demo; import java.sql.*; public class DataBase { public static void main(String[] args) { Connect

Python3.6 連線mysql 資料庫，增刪改查，及多執行緒簡單運用

readme:        匯入 pymysql 連線資料庫，完成資料處理後的增刪改查操作。匯入到其他Python檔案就可以直接呼叫。後面一個檔案是多執行緒操作， 另一個檔案是處理曲線擬合和積分的然後資料和資料庫互動的運用。 aliyunMySQL_test.py im

Java資料庫連線--JDBC基礎知識(操作資料庫：增刪改查)

1 package sql.model; 2 3 import java.util.Date; 4 5 public class Goddess { 6 private Integer id; 7 private String userName; 8 priva

Java通過JDBC連線資料庫的三種方式！！！並對資料庫實現增刪改查

前言 java連線資料庫完整流程為： 1,獲得驅動(driver)，資料庫連線（url）,使用者名稱（username）,密碼（password）基本資訊的三種方式。 2,通過獲得的資訊完成JDBC實現連線資料庫。 注：連線前請匯入jar包，例：連線my

java連線my sql資料庫以及增刪改查方法的實現

1，新建java專案（或者web專案，這裡以java為例），以user表為例子 2，連線資料庫，新建jdbc,properties（資料庫名，使用者名稱，密碼以自己的來寫） 3，這裡我將資料庫的連線程式碼封裝在DBConnectionUtil.java裡面 packag

flask連線mysql資料庫操作增刪改查的簡單封裝函式

Y17 1、建立python資料夾，命名為app，建立並返回一個WGSI應用程式物件 from flask import Flask app = Flask(__name__) # 定義函式封裝路由配置 def path(route, fun, *, methods=['GE

lua 連線mysql資料庫實現增刪改查操作（linux下示例）

（1）linux下連線資料庫： mysql -u root -p，-u 指定登入使用者，-p 指定密碼。 [[email protected]18 develop]$ mysql -u root -p Enter password: Welcome to the MySQ

Hibernate入門 連線Oracle資料庫 簡單增刪改查

最近入門學習Hibernate框架，想分享總結一下踩過的坑和成功後的案例。 所用軟體： eclipse Oracle資料庫 （如果你使用的不是Oracle資料庫可以修改hibernate.cfg.xml裡面的配置）   現在，我們來看一下我們的包結構和資料庫表結構 第一步：建立eclip

C++ API方式連線mysql資料庫實現增刪改查

轉自 http://www.bitscn.com/pdb/mysql/201407/226252.html 一、環境配置 1，裝好mysql，新建一個C++控制檯工程（從最簡單的弄起，這個會了，可以往任何c++工程移植），在vs2010中設定，工程--屬性--VC++目

golang連線mysql資料庫實現增刪改查

golang本身沒有提供連線mysql的驅動，但是定義了標準介面供第三方開發驅動。這裡連線mysql可以使用第三方庫，第三方庫推薦使用https://github.com/Go-SQL-Driver/MySQL這個驅動，更新維護都比較好。下面演示下具體的使用，完整程式碼示例可