JDBC如何连接SQL Server数据库实现增删改查

这篇具有很好参考价值的文章主要介绍了JDBC如何连接SQL Server数据库实现增删改查。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

目录

一、连接前准备

 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连接sql server数据库,Java,数据库,sql,java

JDBC访问数据库的方式 

一、连接前准备

 1. 环境配置

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

jdbc连接sql server数据库,Java,数据库,sql,java

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

jdbc连接sql server数据库,Java,数据库,sql,java

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


 重启后,按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

 例如下表就准确指定了相应的版本:

JAR JDBC 版本法规遵从性 推荐的 Java 版本 说明
mssql-jdbc-12.4.0.jre8.jar 4.2 8 需要 Java Runtime Environment (JRE) 1.8。 使用 JRE 1.7 或更低版本会引发异常。
mssql-jdbc-12.4.0.jre11.jar 4.3 20 需要 Java Runtime Environment (JRE) 11.0 或更高版本。 使用 JRE 10.0 或更低版本会引发异常。

然后在此链接下载合适的jar包:发行说明 - JDBC Driver for SQL Server | Microsoft Learnhttps://learn.microsoft.com/zh-cn/sql/connect/jdbc/release-notes-for-the-jdbc-driver?view=sql-server-ver16#84

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

jdbc连接sql server数据库,Java,数据库,sql,java

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

jdbc连接sql server数据库,Java,数据库,sql,java

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

4. 导入JDBC包

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

 jdbc连接sql server数据库,Java,数据库,sql,java

jdbc连接sql server数据库,Java,数据库,sql,java

jdbc连接sql server数据库,Java,数据库,sql,java

jdbc连接sql server数据库,Java,数据库,sql,java

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

 二、连接SQL Server

jdbc连接sql server数据库,Java,数据库,sql,java

 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);//把属性名输入arr
                    System.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<count){
                        //输出属性名
                        System.out.print(rsmd.getColumnName(i) + "["+rsmd.getColumnTypeName(i)+"("+rsmd.getColumnDisplaySize(i)+")],");
                    }else System.out.print(rsmd.getColumnName(i) + "["+rsmd.getColumnTypeName(i)+"("+rsmd.getColumnDisplaySize(i)+")]");
                }
            }
            System.out.println();
            //输入需要添加的值用英文逗号分隔
            String values =in.next();
            String[] arr = values.split(",");
            for(int i = 0; i<arr.length; i++){
                //把每个分量按SQL格式依次输入到对象s1中
                if(i<arr.length-1)
                {
                    s1.append("'").append(arr[i]).append("',");
                }else s1.append("'").append(arr[i]).append("'");
            }
            String insertSql = "insert into " + tableName + " values("+s1+")";//SQL语句
            sqlStatement.executeUpdate(insertSql);
            System.out.println("Execute Successful !");
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("Execute failed !");
        }
    }

3. 修改数据

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 !");
        }
    }

4. 删除数据

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 !");
        }
    }

5. 拓展

数据库增删改功能定义好后我们可以进一步整合,首先在main方法中调用并测试。

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

我们可以发现,在操作表时,我们必须在方法中输入实参:表名,如果操作不同的表就需要再次修改实参,下面我们定义一个可以自行选择数据库表名的方法。

第一步,在class ConnectDb中声明一个tableName全局变量。

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

第二步,创建TableList方法,输出数据库内所有表,并要求选择一个表,将表名赋给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();
        }
    }

 第三步,补充main方法。

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'));
    }
}

结果展示。

jdbc连接sql server数据库,Java,数据库,sql,java文章来源地址https://www.toymoban.com/news/detail-779711.html

到了这里,关于JDBC如何连接SQL Server数据库实现增删改查的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 如何在CentOS安装SQL Server数据库并实现无公网ip环境远程连接

    简单几步实现在Linux centos环境下安装部署sql server数据库,并结合cpolar内网穿透工具,创建安全隧道将其映射到公网上,获取公网地址,实现在外异地远程连接家里/公司的sqlserver数据库,而无需公网IP,无需设置路由器,亦无需云服务器。 下载 SQL Server 2022 (16.x) Red Hat 存储库配

    2024年02月21日
    浏览(54)
  • 连接数据库报com.microsoft.sqlserver.jdbc.SQLServerException: 驱动程序无法通过使用安全套接字层(SSL)加密与 SQL Server 建立安全连接

    JDBC加载驱动,连接SQLServer 2012 报 java.ext.dirs: C:Program FilesJavajdk1.8.0_331jrelibext;C:WindowsSunJavalibext com.microsoft.sqlserver.jdbc.SQLServerException: 驱动程序无法通过使用安全套接字层(SSL)加密与 SQL Server 建立安全连接。错误:“The server selected protocol version TLS10 is not accepted by client pre

    2023年04月21日
    浏览(101)
  • 如何通过navicat连接SQL Server数据库

           本文介绍如何通过Navicat 连接SQL Server数据库。如果想了解如何连接Oracle数据库,可以参考下边这篇文章。 如何通过Navicat连接Oracle数据库 https://sgknight.blog.csdn.net/article/details/132064235 1、新建SQL Server连接配置         打开Navicat软件,点击连接,选择SQL server,进入配置页

    2024年02月04日
    浏览(64)
  • PyQt5数据库开发1 4.1 SQL Server 2008 R2如何开启数据库的远程连接

    文章目录 前言 步骤/方法 1 使用windows身份登录 2 启用混合登录模式

    2024年02月22日
    浏览(70)
  • C#窗体程序连接SQL Server数据库实现账号登录、账号注册、修改密码、账号注销和实名认证(不定时更新)

    这是本人用Visual Studio2019做的一个C#窗体登录程序,如标题所示,它包含了账号登录、注册账号、修改密码、注销账号和实名认证五个功能。对于有一定基础知识的小伙伴来说,应该不算太难,里面有注释说明,可能咋一看感觉代码运行的逻辑有点乱,不过没关系,相信对你会

    2024年02月02日
    浏览(75)
  • Sql server 连接 Oracle数据库

    前提预警:本机必须装有Oracle客户端 检查是否安装Oracle客户端,并检查TNS信息是否配置完成 1.1、 在cmd中执行 sqlplus ,没有报错并出现Oracle版本号,则表示Oracle已安装 1.2、配置TNS信息(最上面的10.0.0.130可随意定义,eg:test、orcl、qerghasd…) 配置ODBC数据信息 2.1、打开ODBC数据

    2024年02月03日
    浏览(59)
  • VS连接SQL server数据库

    目录 连接数据库 使用dataGridView控件显示表中的数据。 实现基本CRUD操作 打开vs,点击 视图,打开sql资源管理器,添加SQL Server 输入服务器名称,用户名,密码,进行连接。 如图,就可以看到vs已经连接到了自己的数据库,class和song两个数据库 。可以看到class下面有五个表。

    2024年02月09日
    浏览(52)
  • Navicat连接SQL Server数据库

    使用navicat连接sqlserver数据库时必须连接sqlserver驱动,否则的话会连接报错; 按照应用的常理来说都是高版本兼容低版本的驱动; 我这边呢,是一个SQL Server Native Client 11.0的驱动; 大家需要的话可以到SQL Server官网网址去下载各类驱动; 网址:https://docs.microsoft.com/en-us/sql/con

    2024年02月08日
    浏览(56)
  • Bug解决:获取JDBC连接失败;嵌套异常是java.sql.SQLException:无法从底层数据库获取连接

    出现的问题 Failed to obtain JDBC Connection; nested exception is java.sql.SQLException: Connections could not be acquired from the underlying database! 说白了就是连接数据库出问题了,寻找了一个半小时才发现错误 从头到尾检查了一遍,这里使用的是C3P0连接池。 解决方法 1.如果使用的是c3p0连接池,prop

    2023年04月08日
    浏览(51)
  • 【远程连接 多个SQL SERVER数据库实例】

    在公司电脑上同时安装了SQL SERVER2012和SQL SERVER2019,分别设置了不同的实例,现用VPN连接公司电脑上的两个数据库实例,做一些记录。 如图所示,分别有MSSQLSERVER2012与MSSQLSERVER2019两个不同的实例,分别查看实例对应的TCP/IP 为数据库引擎访问配置 Windows 防火墙 - SQL Server | Micro

    2024年02月07日
    浏览(55)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包