抽取JDBC工具類並增刪改查

阿新 • • 發佈：2018-01-31

for 文件 import -c auto -a san pac ext

抽取工具類：

package demo;
/*
 * 工具類
 */

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class JDBCUtils1 {

    public static Connection getConnection() {
        Connection conn = null;
        try {
            Class.forName( 
"com.mysql.jdbc.Driver");
            String url = "jdbc:mysql://localhost:3306/mybase";
            String username = "root";
            String password = "xuyiqing";
            conn = DriverManager.getConnection(url, username, password);
        } catch (Exception ex) {
            ex.printStackTrace();
        }
         
return conn;
    }

    public static void release(Connection conn, PreparedStatement pstmt, ResultSet rs) {
        if (rs != null) {
            try {
                rs.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        if (pstmt != null 
) {
            try {
                pstmt.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        if (conn != null) {
            try {
                conn.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

    }
}

View Code

數據準備：

CREATE DATABASE mybase;
USE mybase;
CREATE TABLE users(
uid INT PRIMARY KEY AUTO_INCREMENT,
username VARCHAR(64),
upassword VARCHAR(64)
);
INSERT INTO users (username,upassword) VALUES("zhangsan","123"),("lisi","456"),("wangwu","789");
SELECT * FROM users;

View Code

根據主鍵id查詢：

package demo;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

import org.junit.Test;

public class TestUtils {

    @Test
    public void testFindUserById() {
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        try {
            conn = JDBCUtils1.getConnection();
            String sql = "select * from users where uid=?";
            pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, 2);
            rs = pstmt.executeQuery();
            while (rs.next()) {
                System.out.println(rs.getString(2) + "----" + rs.getString("upassword"));
            }
        } catch (Exception ex) {
            ex.printStackTrace();
        } finally {
            JDBCUtils1.release(conn, pstmt, rs);
        }
    }
}

View Code

第二種抽取工具類方式：

配置文件（src目錄下）：db.properties

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/mybase
username=root
password=xuyiqing

View Code

工具類：

package demo;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ResourceBundle;

public class JDBCUtils2 {
    
    public static String driver;
    public static String url;
    public static String username;
    public static String password;
    
    static{
        ResourceBundle bundle = ResourceBundle.getBundle("db");
        driver = bundle.getString("driver");
        url = bundle.getString("url");
        username = bundle.getString("username");
        password = bundle.getString("password");
    }
    
    public static Connection getConnection() {
        Connection conn = null;
        try {
            Class.forName(driver);
            conn = DriverManager.getConnection(url, username, password);
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        return conn;
    }

    public static void release(Connection conn, PreparedStatement pstmt, ResultSet rs) {
        if (rs != null) {
            try {
                rs.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        if (pstmt != null) {
            try {
                pstmt.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        if (conn != null) {
            try {
                conn.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

    }
}

View Code

插入數據：

package demo;

import java.sql.Connection;
import java.sql.PreparedStatement;

import org.junit.Test;

public class TestUtils {
    @Test
    public void testAdd() {
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            conn = JDBCUtils2.getConnection();
            String sql = "insert into users values(null,?,?)";
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, "xiaoming");
            pstmt.setString(2, "666");
            int row = pstmt.executeUpdate();
            if (row > 0) {
                System.out.println("添加成功");
            } else {
                System.out.println("添加失敗");
            }
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            JDBCUtils2.release(conn, pstmt, null);
        }
    }
}

View Code

第三種抽取工具類方式：

依然使用db.properties配置文件：

package demo;

import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.Properties;

public class JDBCUtils3 {
    public static String driver;
    public static String url;
    public static String username;
    public static String password;

    static {
        try {
            ClassLoader classLoader = JDBCUtils3.class.getClassLoader();
            InputStream is = classLoader.getResourceAsStream("db.properties");
            Properties props = new Properties();
            props.load(is);
            driver = props.getProperty("driver");
            url = props.getProperty("url");
            username = props.getProperty("username");
            password = props.getProperty("password");
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    public static Connection getConnection() {
        Connection conn = null;
        try {
            Class.forName(driver);
            conn = DriverManager.getConnection(url, username, password);
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        return conn;
    }

    public static void release(Connection conn, PreparedStatement pstmt, ResultSet rs) {
        if (rs != null) {
            try {
                rs.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        if (pstmt != null) {
            try {
                pstmt.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        if (conn != null) {
            try {
                conn.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

    }
}

View Code

刪除和修改數據：

package demo;

import java.sql.Connection;
import java.sql.PreparedStatement;

import org.junit.Test;

public class TestUtils {

    /*
     * 刪除
     */
    @Test
    public void testDelete() {
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            conn = JDBCUtils3.getConnection();
            String sql = "delete from users where uid=?";
            pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, 3);
            int row = pstmt.executeUpdate();
            if (row > 0) {
                System.out.println("刪除成功");
            } else {
                System.out.println("刪除失敗");
            }
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            JDBCUtils3.release(conn, pstmt, null);
        }
    }

    /*
     * 修改
     */
    @Test
    public void testUpdate() {
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            conn = JDBCUtils3.getConnection();
            String sql = "update users set upassword=? where uid=?";
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, "123456789");
            pstmt.setInt(2, 2);
            int row = pstmt.executeUpdate();
            if (row > 0) {
                System.out.println("修改成功");
            } else {
                System.out.println("修改失敗");
            }
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            JDBCUtils3.release(conn, pstmt, null);
        }
    }
}

View Code

抽取JDBC工具類並增刪改查

for 文件 import -c auto -a san pac ext 抽取工具類： package demo; /* * 工具類 */ import java.sql.Connection; import java.sql.DriverManager; imp

JDBC工具類及增刪改查

資料庫： CREATE DATABASE mydb; #使用資料庫 USE mydb; ###建立分類表 CREATE TABLE category( cid INT PRIMARY KEY AUTO_INCREMENT , cname VA

複習：JDBC工具類並實現增刪改查

JDBC工具類 package bull01.JDBCbasis; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOExceptio

JavaWeb學習筆記6——JDBC連線MySql進行增刪改查並分頁顯示

資料庫的增、刪、改、查是非常重要的操作，只要程式是關於資料庫的操作，無論程式大小，歸根結底都是這4種操作的使用。連線MySql資料庫的過程： 1、註冊驅動 DriverManager.registerDriver(new com.mysql.jdbc.Driver()

通過JDBC進行簡單的增刪改查（以MySQL為例）

mage ron end main exce javax xtend 探索 rman 通過JDBC進行簡單的增刪改查（以MySQL為例）目錄前言：什麽是JDBC 一、準備工作（一）：MySQL安裝配置和基礎學習二、準備工作（二）：下載數據庫對應的jar包並

c++實現字符串類的增刪改查

析構函數沒有 int insert his 字符 out delet 索引 #include<iostream> using namespace std; class mystring{ public: mystring():mystr(NULL){}

通過JDBC進行簡單的增刪改查（以MySQL為例）（轉載）

IE trac archive solver ttl 賦值 TP 定義 for 轉載：https://www.cnblogs.com/wuyuegb2312/p/3872607.html 目錄前言：什麽是JDBC 一、準備工作（一）：MySQL安裝配置和基礎學習二、準備

redis 5種數據類型增刪改查

span list field diff nio 分享 col tar redis 1 # 字符串 string 2 （1）添加數據 3 set key value # 添加一條 4 mset key value [key value...] # 添加多條

JDBC實現簡單的增刪改查

exceptio 介紹 cde sna arch png into 註冊 sets JDBC的開發步驟 * a: 步驟介紹 1.註冊驅動告知JVM使用的是哪一個數據庫的驅動 2.獲得連接使用JDBC中的類,完成對MySQL數據庫的連接 3.獲

JDBC連線MySQL的增刪改查

介紹：JDBC（Java DataBase Connectivity, Java資料庫連線）是一種用於執行SQL語句的Java API，可以為多種關係資料庫提供統一訪問，它由一組用 Java語言編寫的類和介面組成。 JDBC操作資料庫型別： MySQL資料庫準備

JavaWeb學習筆記6——JDBC連線MySql進行增刪改查

資料庫的增、刪、改、查是非常重要的操作，只要程式是關於資料庫的操作，無論程式大小，歸根結底都是這4種操作的使用。連線MySql資料庫的過程： 1、註冊驅動 DriverManager.registerDriver(new com.mysql.jdbc.Driver

JDBC實現資料庫的增刪改查操作例項

import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import com.mysql.jdbc.PreparedStatement

集合類的增刪改查

List的增刪改查 package daili; import java.util.ArrayList; import java.util.Collection; import java.util.Collections; import java.util.Iterato

Java 利用 JDBC 連線 Sqlsever2012 實現增刪改查

所需驅動檔案下載 http://download.csdn.net/detail/u012320991/9378730 資料表如下：執行結果如下：解決過程(預設SqlSever 已安裝並配置好)：下載 JDBC 4.0 For SqlSever --->

JDBC進行簡單的增刪改查

通過JDBC進行簡單的增刪改查（以MySQL為例）目錄前言：什麼是JDBC 一、準備工作（一）：MySQL安裝配置和基礎學習二、準備工作（二）：下載資料庫對應的jar包並匯入三、JDBC基本操作 (1)定義記錄的類（可選） (2)連線的獲取 (3)inse

JDBC Spring 之JdbcTemplate 增刪改查操作

之前簡單介紹了JDBC CRUD的操作，接下來我為大家來講解一下JDBC 使用Spring框架來進行CURD（增刪改查操作）使用Spring中的JdbcTemplate之前應該給一個數據源來獲得連線。 package cn.itcast.jdbc; import jav

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

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

java基於jdbc操作mysql實現增刪改查日誌完整程式碼不足之處歡迎留言指導

1、建立Java Project專案 2、匯入Jar包 3、建立資料庫 //根據實體類建立資料庫 4、建立實體類 (Bm.java) public class Bm { private int id; private String rq;

jdbc對mysql進行增刪改查操作(Statement)

創立資料庫school 創立表格students create table students( id INT NOT NULL AUTO_INCREMENT, name VARCHAR(20) NOT NULL, sex VARCHAR(4) NOT N

14.JDBC原理介紹及增刪改查示範

本文為《Spark大型電商專案實戰》系列文章之一，主要介紹JDBC的原理以及對MySQL資料庫增刪改查的具體實現過程。 JDBC原理介紹 JDBC代表了JDK提供的一套面向資料庫的一套開發介面，大部分僅僅是介面而已，Java應用程式光有JDBC是操作不

抽取JDBC工具類並增刪改查

相關推薦