java连接sql数据库项目

项目简介

本项目是一个使用Java连接SQL数据库的示例，主要演示了如何使用Java语言和JDBC（Java Database Connectivity）技术连接到SQL Server数据库，并进行基本的增删改查操作。

环境准备

1、安装Java开发环境（JDK）

2、安装SQL Server数据库

3、下载并导入JDBC驱动（sqljdbc4.jar）

项目结构

java连接sql数据库项目
├─src
│  └─main
│      └─java
│          └─com
│              └─example
│                  Main.java
├─resources
│  └─sqljdbc4.jar
└─test.sql

代码实现

1、编写数据库连接工具类DBUtil.java

package com.example;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class DBUtil {
    private static final String URL = "jdbc:sqlserver://localhost:1433;databaseName=test";
    private static final String USER = "username";
    private static final String PASSWORD = "password";
    private static final String DRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
    static {
        try {
            Class.forName(DRIVER);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    public static Connection getConnection() {
        Connection conn = null;
        try {
            conn = DriverManager.getConnection(URL, USER, PASSWORD);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return conn;
    }
}

2、编写主类Main.java，实现增删改查操作

package com.example;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Scanner;
public class Main {
    public static void main(String[] args) {
        // 查询操作
        selectData();
        // 插入操作
        insertData();
        // 更新操作
        updateData();
        // 删除操作
        deleteData();
    }
    private static void selectData() {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            conn = DBUtil.getConnection();
            stmt = conn.createStatement();
            rs = stmt.executeQuery("SELECT * FROM users");
            while (rs.next()) {
                System.out.println("id: " + rs.getInt("id") + ", name: " + rs.getString("name"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            close(rs, stmt, conn);
        }
    }
    private static void insertData() {
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            conn = DBUtil.getConnection();
            pstmt = conn.prepareStatement("INSERT INTO users (name) VALUES (?)");
            pstmt.setString(1, "张三");
            pstmt.executeUpdate();
            System.out.println("插入成功");
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            close(pstmt, null, conn);
        }
    }
    private static void updateData() {
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            conn = DBUtil.getConnection();
            pstmt = conn.prepareStatement("UPDATE users SET name=? WHERE id=?");
            pstmt.setString(1, "李四");
            pstmt.setInt(2, 1); // 根据实际需求设置条件值，id=1，表示更新id为1的用户信息，这里为了演示，直接设置为1。