目录

一、连接前准备

 1. 环境配置

 2. 下载JAR包

3. 添加环境变量

4. 导入JDBC包

 二、连接SQL Server

 三、实现增删改查

1. 查询数据

2. 添加数据

3. 修改数据

4. 删除数据

5. 拓展

JDBC的全称是Java数据库连接(Java DataBase Connectivity) ，应用程序通过JDBC连接到数据库，使用SQL语句对数据库中的表进行查询、增加、修改、删除等操作。此文章提供JDBC连接SQL Server的所有步骤，帮助大家实现Java对数据库的增删改查！

JDBC访问数据库的方式 

一、连接前准备

 1. 环境配置

我们右键点击“开始”菜单打开“计算机管理”，接下来以此打开树形菜单，启用所有协议。

 下一步，打开控制面版—>程序—>程序与功能—>启用或关闭Windows功能 —>勾选 Telnet客户端

 接下来，重启计算机，在此之前请务必点击“收藏”或“关注”，以免找不到下一步教程。

 重启后，按Win+R，输入cmd后按回车，输入命令：

telnet localhost 1433

进入只有光标闪烁的空白页面即通信成功。

 2. 下载JAR包

下面讲解的方法都是基于 IntelliJ IDEA 软件，如果是 Eclipse 会有细微差别。

首先，在连接JDBC之前，需要下载MS JDBC Driver包，下载地址：下载 Microsoft SQL Server JDBC 驱动程序https://learn.microsoft.com/zh-cn/sql/connect/jdbc/download-microsoft-jdbc-driver-for-sql-server

那么如何选择正确的JDBC呢？

请参照以下对应规则下载相应的JDBC驱动版本。

从 Microsoft JDBC Driver 12.2 for SQL Server 开始，支持 Java 开发工具包 (JDK) 19.0 和 Java Runtime Environment (JRE) 19.0。从 Microsoft JDBC Driver 11.2 for SQL Server 开始，支持 Java 开发工具包 (JDK) 18.0 和 Java Runtime Environment (JRE) 18.0。从 Microsoft JDBC Driver 10.2 for SQL Server 开始，支持 Java Development Kit (JDK) 17.0 和 Java Runtime Environment (JRE) 17.0。从 Microsoft JDBC Driver 9.4 for SQL Server 开始，支持 Java Development Kit (JDK) 16.0 和 Java Runtime Environment (JRE) 16.0。从 Microsoft JDBC Driver 9.2 for SQL Server 开始，支持 Java Development Kit (JDK) 15.0 和 Java Runtime Environment (JRE) 15.0。从 Microsoft JDBC Driver 8.4 for SQL Server 开始，支持 Java Development Kit (JDK) 14.0 和 Java Runtime Environment (JRE) 14.0。从 Microsoft JDBC Driver 8.2 for SQL Server 开始，支持 Java Development Kit (JDK) 13.0 和 Java Runtime Environment (JRE) 13.0。从 Microsoft JDBC Driver 7.4 for SQL Server 开始，支持 Java Development Kit (JDK) 12.0 和 Java Runtime Environment (JRE) 12.0。从 Microsoft JDBC Driver 7.2 for SQL Server 开始，支持 Java Development Kit (JDK) 11.0 和 Java Runtime Environment (JRE) 11.0。从 Microsoft JDBC Driver 7.0 for SQL Server 开始，支持 Java Development Kit (JDK) 10.0 和 Java Runtime Environment (JRE) 10.0。从 Microsoft JDBC Driver 6.4 for SQL Server 开始，支持 Java Development Kit (JDK) 9.0 和 Java Runtime Environment (JRE) 9.0。从 Microsoft JDBC Driver 4.2 for SQL Server 开始，支持 Java Development Kit (JDK) 8.0 和 Java Runtime Environment (JRE) 8.0。 对 JDBC 规范 API 的支持已扩展为包含 JDBC 4.1 和 4.2 API。从 Microsoft JDBC Driver 4.1 for SQL Server 开始，支持 Java Development Kit (JDK) 7.0 和 Java Runtime Environment (JRE) 7.0。从 Microsoft JDBC Driver 4.0 for SQL Server 开始，JDBC 规范 API 的JDBC 驱动程序支持扩展为包含 JDBC 4.0 API。 已在 Java 开发工具包 (JDK) 6.0 和 Java 运行时环境 (JRE) 6.0 中引入了 JDBC 4.0 API。 JDBC 4.0 是 JDBC 3.0 API 的超集。

更详细的与你的JDK版本匹配的JAR包可以从下面的官网文档链接中查找，系统要求 - JDBC Driver for SQL Server | Microsoft Learn

 例如下表就清晰描述了你所下载的JDBC驱动压缩包中存放的两个.jar包所适应的JDK版本。

下载完后解压缩并打开，可以在目录中找到后缀名为.jar的文件，即需要导入到项目工程的包。

3. 添加环境变量

在添加两个包含.jar的环境变量，例如：

变量名：CLASSPATH
变量值：C:\Program Files\Microsoft JDBC Driver 11.2 for SQL Server\sqljdbc_12.2\chs\mssql-jdbc-12.2.0.jre8.jar;C:\Program Files\Microsoft JDBC Driver 11.2 for SQL Server\sqljdbc_12.2\chs\mssql-jdbc-12.2.0.jre11.jar

打开环境变量的方式。Win7：桌面或开始菜单找到“计算机”->右键单击选择"属性"->高级系统设置->环境变量，Win10：设置->系统->关于->高级系统设置->环境变量，Win11：设置->系统->系统信息->高级系统设置->环境变量。

4. 导入JDBC包

然后我们进入IDEA，点击File—>Priject Structure—>Libraries—> + —>Java —>Select Library Files，选择sqljdbc.jar

 如果能在首页看到External Libraries下面有sqljdbc42即表示导入成功。

 二、连接SQL Server

 JDBC的实现步骤

通过上图我们了解到，想要实现JDBC首先就需要加载并注册数据库驱动。第一步，加载并注册驱动可以通过java.lang.Class类的静态方法forName实现。

Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");

 第二步，通过DriverManager类的getConnection方法实现数据库连接。

String databaseName = "数据库名";
String username = "用户名";
String password = "密码";
String dbURL = "jdbc:sqlserver://localhost:1433;databaseName=" + databaseName;
Connection conn = DriverManager.getConnection(dbURL, username, password);

第三步，try…catch抛出异常。

try {Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver";);String dbURL = "jdbc:sqlserver://localhost:1433;databaseName=" + databaseName;Connection conn = DriverManager.getConnection(dbURL, username, password);System.out.println("Successful Connection !");} catch (Exception e) {e.printStackTrace();System.out.println("Connection failed !");}

 三、实现增删改查

实现增删改查之前，为了阅读方便，我们需要新建一个容纳这些功能的类，并且创建两个类变量，方便在各个方法中调用。这里我们将类命名为ConnectionDb，创建Connection对象conn。

public class ConnectDb {public Connection conn;
}

接下来创建四个方法：查询、增加、修改、删除。

public class ConnectDb {private Connection conn;public void SelectAll(){}//查询表public void AddValue(){}//添加数据public void DeleteValue(){}//修改数据public void ModifyValue(){}//删除数据
}

下面就是实现方法的代码： 

1. 查询数据

public void SelectAll(String tableName,String where) {ResultSetMetaData rsmd = null;try {//try catch判断是否有异常Statement sqlStatement = conn.createStatement();//创建sql语句String sql = "select * from " + tableName+" "+where;ResultSet rs = sqlStatement.executeQuery(sql);//执行sql语句//下面根据该table输出属性组和所有元组rsmd = rs.getMetaData();//获取属性名String []arr = new String[0];if(rsmd != null) {int count = rsmd.getColumnCount();//统计属性个数arr = new String[count];for (int i = 1; i <= count; i++) {arr[i-1] = rsmd.getColumnName(i);//把属性名输入arrSystem.out.print(rsmd.getColumnName(i)+"  ");//输出属性名}}System.out.println();//换一行，保证格式正确while (rs.next()) {//判断是否存在下一行，如果存在，就使用foreach循环输出元组for (String s : arr) {System.out.print(rs.getString(s) + "  ");}System.out.println();//控制格式}} catch (Exception e) {e.printStackTrace();}}

2. 添加数据

public void AddValue(String tableName){ResultSetMetaData rsmd = null;Scanner in = new Scanner(System.in);StringBuilder s1 = new StringBuilder();//创建字符串对象try {Statement sqlStatement = conn.createStatement();//创建语句对象String sql = "select * from " + tableName;ResultSet rs = sqlStatement.executeQuery(sql);//执行sql语句//下面根据该table输出属性组rsmd = rs.getMetaData();//获取属性名System.out.print("Input values according to :");if (rsmd != null) {int count = rsmd.getColumnCount();//统计属性个数for (int i = 1; i <= count; i++) {if(i

public void ModifyValue(String tableName){ResultSetMetaData rsmd = null;Scanner in = new Scanner(System.in);try {Statement sqlStatement = conn.createStatement();//创建sql语句String sql = "select * from " + tableName;ResultSet rs = sqlStatement.executeQuery(sql);//执行sql语句//下面根据该table输出属性组rsmd = rs.getMetaData();//获取属性名Map map = new HashMap();System.out.print("Filter column. ");if (rsmd != null) {int count = rsmd.getColumnCount();//统计属性个数for (int i = 1; i <= count; i++) {map.put(i,rsmd.getColumnName(i));System.out.print("["+i+": "+rsmd.getColumnName(i)+"]");//输出属性名}}System.out.print("\nInput the number: ");//筛选属性Object num = in.nextInt();System.out.print("Filter value: ");//筛选元组String value = in.next();SelectAll(tableName,"where "+map.get(num)+"='"+value+"'");//调用查询方法，查询筛选数据System.out.println("Are these values that need to be modified? [Y/N]");String YesOrNo = in.next();if(YesOrNo.charAt(0) == 'Y'){System.out.println("Which column should be modified?");if (rsmd != null) {//输出属性名int count = rsmd.getColumnCount();for (int i = 1; i <= count; i++) {System.out.print("["+i+": "+rsmd.getColumnName(i)+"]");}}System.out.print("\nInput the number: ");//输入需要修改的属性int num2 = in.nextInt();System.out.println("What value is modified to?");//修改成什么值String value2 = in.next();String modifySql = "update "+tableName+" set "+map.get(num2)+"='"+value2+"'"+" where "+map.get(num)+"="+"'"+value+"'";sqlStatement.executeUpdate(modifySql);System.out.println("Execute Successful !");} else if (YesOrNo.charAt(0) == 'N') {ModifyValue(tableName);//如果不修改以上内容，重新选择需要修改的元组} else System.out.println("Input error! System exit.");//除Y和N以外的键自动退出} catch (Exception e) {e.printStackTrace();System.out.println("Execute failed !");}}

public void DeleteValue(String tableName){//选择列名，询问是否删除以下数据，选择Y删除。ResultSetMetaData rsmd = null;Scanner in = new Scanner(System.in);try {Statement sqlStatement = conn.createStatement();//创建sql语句String sql = "select * from " + tableName;ResultSet rs = sqlStatement.executeQuery(sql);//执行sql语句//下面根据该table输出属性组rsmd = rs.getMetaData();//获取属性名Map map = new HashMap();System.out.print("Filter column. ");//筛选属性if (rsmd != null) {//输出属性名int count = rsmd.getColumnCount();for (int i = 1; i <= count; i++) {map.put(i,rsmd.getColumnName(i));System.out.print("["+i+": "+rsmd.getColumnName(i)+"]");}}System.out.print("\nInput the number: ");Object num = in.nextInt();System.out.println("Filter value: ");//筛选元组String value = in.next();System.out.println("These values will be deleted.");SelectAll(tableName,"where "+map.get(num)+"='"+value+"'");//调用查询方法，查询需要删除的元组System.out.println("[Y/N]?");String YesOrNo = in.next();if(YesOrNo.charAt(0) == 'Y'){String deleteSql = "delete from "+tableName+" where "+map.get(num)+"='"+value+"'";sqlStatement.executeUpdate(deleteSql);//执行删除语句System.out.println("Execute Successful !");} else if (YesOrNo.charAt(0) == 'N') {DeleteValue(tableName);//如果不删除，重新选择需要删除的元组} else System.out.println("Input error! System exit.");//除Y和N以外的键自动退出} catch (Exception e) {e.printStackTrace();System.out.println("Execute failed !");}}

connectDb.SelectAll("表名","where条件句");//where条件句为空则查询所有元组
connectDb.AddValue("表名");//增加元组
connectDb.DeleteValue("表名");//删除元组
connectDb.ModifyValue("表名");//修改元组

public class ConnectDb {public String tableName;...
}

public void TableList(){Scanner in = new Scanner(System.in);Map map = new HashMap();int i = 0;try {DatabaseMetaData metaData = conn.getMetaData();ResultSet mrs = metaData.getTables(null, null, null, new String[]{"TABLE"});while (mrs.next()) {i++;map.put(i, mrs.getString(3));System.out.println("[" + i + ": " + mrs.getString(3) + "]");}System.out.print("Input the number: ");int num = in.nextInt();this.tableName = (String) map.get(num);}catch (Exception e){e.printStackTrace();}}

import java.util.Scanner;public class Main {public static void main(String[] args) {ConnectDb connectDb = new ConnectDb("数据库名","用户名","密码");System.out.println("Please choose a table.");connectDb.TableList();String n;do {//Y/N判断是否继续操作数据表System.out.println("Please choose an operation.\n[1: Select all rows],[2: Add values],[3: Delete values],[4: Modify values]");Scanner in = new Scanner(System.in);System.out.print("Input the number: ");int i = in.nextInt();switch (i) {case 1:connectDb.SelectAll(connectDb.tableName,"");//查询所有元组break;case 2:connectDb.AddValue(connectDb.tableName);//增加元组break;case 3:connectDb.DeleteValue(connectDb.tableName);//删除元组break;case 4:connectDb.ModifyValue(connectDb.tableName);//修改元组}System.out.println("Do you wanna continue to operate? [Y/N]");n = in.next();}while((n.charAt(0) == 'Y') && (n.charAt(0) != 'N'));}
}

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！