程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> JAVA編程 >> 關於JAVA >> JAVA運用JDBC技術操作SqlServer數據庫

JAVA運用JDBC技術操作SqlServer數據庫

編輯:關於JAVA

JAVA運用JDBC技術操作SqlServer數據庫。本站提示廣大學習愛好者:(JAVA運用JDBC技術操作SqlServer數據庫)文章只能為提供參考,不一定能成為您想要的結果。以下是JAVA運用JDBC技術操作SqlServer數據庫正文


  JDBC(Java Data Base Connectivity,Java數據庫銜接)是一種用於執行SQL語句的Java API,可以為多種關系數據庫提供一致訪問,它由一組用Java言語編寫的類和接口組成。JDBC提供了一種基准,據此可以構建更初級的工具和接口,使數據庫開發人員可以編寫數據庫使用順序。 JDBC並不能直接訪問數據庫,需求借助於數據庫廠商提供的JDBC驅動順序。

數據庫銜接
        假如要在Java訪問數據庫,首先要加載一個數據庫驅動,數據庫驅動只需求在第一次訪問時加載一次。然後再每次訪問數據庫時創立一個Connection實例,獲取數據庫銜接,這樣就可以執行操作數據庫的SQL語句。最後用完後釋放掉數據庫的銜接。
數據庫驅動類
        不同的數據庫完成JDBC接口不同,所以就發生了不同的數據庫驅動包。驅動包就包括一些擔任數據庫銜接的類,把我們要操作的SQL語句傳遞到外面去。我的PC用的是SQL2012,所以我們要去這裡http://www.microsoft.com/zh-cn/search/DownloadResults.aspx?q=jdbc下載驅動

下完後在新建的java_project導入驅動包

右擊選中項目>>Build Path >>Add External Archives... 選中下載解壓的文件

導入成功後的項目:

package com.Project_DataBase01;

import java.sql.Connection;
import java.sql.DriverManager;

public class SelectQuery {
    
    private Connection conn;
    
    /*
     * 創立一個前往Connection的辦法
     */
    public Connection getConnection(){
        try {
            Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
            System.out.println("數據庫驅動加載成功");
            conn=DriverManager.getConnection("jdbc:sqlserver://localhost:1433;DatabaseName=java_conn_test","sa","123456");
            if(conn==null){
                System.out.println("數據庫銜接失敗");
                System.out.println("-----------------------");
            }else {
                System.out.println("數據庫銜接成功");
                System.out.println("-----------------------");
            }
        } catch (Exception e) {
            // TODO: handle exception
            e.printStackTrace();
        }
        return conn;
    }

}

停止SqlServe數據庫java_conn_test中的tb_User停止數據的增刪改查。

package com.Project_DataBase01;

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

public class StartMain {
    
    private static Connection conn;

    public static void main(String[] args) {
        // TODO Auto-generated method stub
        
        conn=new SelectQuery().getConnection();
        
        GetInsert();
        GetSelect();
        
        GetUpdate();
        GetSelect();
        
        GetDelete();
        GetSelect();
    }

    /*
     * INSERT
     */
    public static void GetInsert(){
        if(conn!=null){
            //INSERT 
            System.out.println("-----------INSERT------------");
            int x=1+(int)(Math.random()*5000);
            String insert_str="INSERT INTO tb_User (UserName,UserPwd,UserId) VALUES ('name_"+x+"','pwd_"+x+"',NEWID())";
            try {
                Statement insertstatement=conn.createStatement();
                int result= insertstatement.executeUpdate(insert_str);
                if(result>0){
                    System.out.println("添加成功");
                    System.out.println("-----------------------");
                }
                else {                    
                    System.out.println("添加失敗");
                    System.out.println("-----------------------");
                }
            } catch (Exception e) {
                System.out.println("添加失敗");
                System.out.println("-----------------------");
                // TODO: handle exception
            }
        }
        else {
            System.out.println("請反省數據庫銜接");
            System.out.println("-----------------------");
        }
    }
    
    /*
     * SELECT
     */
    public static void GetSelect(){
        if(conn!=null){
            
            //SELECT
            System.out.println("-----------SELECT------------");
            String select_str=" SELECT * FROM tb_User ";
            try {
                PreparedStatement selectps=conn.prepareStatement(select_str);
                ResultSet rs=selectps.executeQuery();
                while (rs.next()) {
                    String name=rs.getString("UserName");
                    String pwd=rs.getString("UserPwd");
                    String UserId=rs.getString("UserId");
                    System.out.println(name+"\t"+pwd+"\t"+UserId);
                }
                System.out.println("查詢成功");
                System.out.println("-----------------------");
            } catch (Exception e) {
                // TODO: handle exception
                System.out.println("查詢失敗");
                System.out.println("-----------------------");
            }
        }
        else {
            System.out.println("請反省數據庫銜接");
            System.out.println("-----------------------");
        }
    }

    /*
     * UPDATE
     */
    public static void GetUpdate(){
        if(conn!=null){
            //UPDATE
            System.out.println("-----------INSERT------------");
            String update_str="UPDATE tb_User SET UserPwd=UserPwd+'xxxxxxxx' WHERE UserId='fa562573-218a-4205-b67d-ebdfac3f8329'";
            try {
                Statement updatestatement=conn.createStatement();
                int result=updatestatement.executeUpdate(update_str);
                if(result>0){
                    System.out.println("修正成功!");
                    System.out.println("-----------------------");
                }else {
                    System.out.println("修正失敗");
                    System.out.println("-----------------------");
                }
            } catch (Exception e) {
                // TODO: handle exception
                System.out.println("修正失敗");
                System.out.println("-----------------------");
            }
        }
        else {
            System.out.println("請反省數據庫銜接");
            System.out.println("-----------------------");
        }
    }
    
    /*
     * DELETE
     */
    public static void GetDelete(){
        if(conn!=null){
            //DELETE 
            System.out.println("-----------DELETE------------");
            String delete_str="DELETE tb_User WHERE UserId!='fa562573-218a-4205-b67d-ebdfac3f8329'";
            try {
                Statement deletestatement=conn.createStatement();
                int result=deletestatement.executeUpdate(delete_str);
                if(result>0){
                    System.out.println("刪除成功!");
                    System.out.println("-----------------------");
                }else {
                    System.out.println("刪除失敗");
                    System.out.println("-----------------------");
                }
            } catch (Exception e) {
                // TODO: handle exception
                System.out.println("刪除失敗");
                System.out.println("-----------------------");
            }
        }
        else {
            System.out.println("請反省數據庫銜接");
            System.out.println("-----------------------");
        }
    }

}

運轉順序:

 

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved