美文网首页
使用JTDS连接sqlserver数据库

使用JTDS连接sqlserver数据库

作者: _FireFly_ | 来源:发表于2021-07-07 14:50 被阅读0次

    原文出自 https://blog.csdn.net/fjseryi/article/details/49796549

    Java连接SQL Server 2000数据库时,有两种方法:
    (1)通过Microsoft的JDBC驱动连接。此JDBC驱动共有三个文件,分别是mssqlserver.jar、msutil.jar和msbase.jar。但是Microsoft官网上已经找不到这些驱动,其提供的sqljdbc.jar和sqljdbc4.jar并不支持SQL Server 2000。

    驱动程序名称:com.microsoft.jdbc.sqlserver.SQLServerDriver(即下面的classforname)
    数据库连接URL:jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=dbname(即下面的url)
    (2)通过jTDS驱动连接。下载地址:http://sourceforge.net/projects/jtds/files/jtds/

    驱动程序名称:net.sourceforge.jtds.jdbc.Driver(即下面的classforname)
    数据库连接URL:jdbc:jtds:sqlserver://localhost:1433/dbname(即下面的url)

    采用第二种方法连接时,可能报错:

    java.lang.UnsupportedClassVersionError: net/sourceforge/jtds/jdbc/Driver : Unsupported major.minor version 51.0

    JDK的版本号对应:
    首先下载JTDS(http://sourceforge.net/projects/jtds/files/jtds/),这里有JTDS的各种版本,起初下的是jtds-1.3.1,但在使用中总出现

    ClassNotFound:net.sourceforge.jtds.jdbc.Driver 错误,后来下载了1.2.7版本,解决了这个问题

    package com.wellsoft.xxbs.modules.TimeTask;
    
    import java.sql.*;
    import java.util.ArrayList;
    import java.util.List;
    
    public class ConnectSqlSever {
        private static Connection dbConn = null;
        public static String dbURL = "jdbc:jtds:sqlserver://localhost:1433/testconnect";//数据库路径
        public static String name = "sa";                                                            //数据库账号
        public static String password = "123456";//数据库密码
        public static String select = "select * from [student]";//简单查询语句
    
        public static List<Student> connectSqlSever() {
            List studentList = new ArrayList<Student>();
            try {
                //1.加载驱动
                //Class.forName方法的作用,就是初始化给定的类.而我们给定的MySQL的Driver类中,
                // 它在静态代码块中通过JDBC的DriverManager注册了一下驱动.我们也可以直接使用JDBC的驱动管理器注册mysql驱动.
                // 从而代替使用Class.forName.
                Class.forName("net.sourceforge.jtds.jdbc.Driver");
    
                //2.连接
                dbConn = DriverManager.getConnection(dbURL, name, password);
                System.out.println("连接数据库成功!");
                PreparedStatement statement = null;
    
                statement = dbConn.prepareStatement(select);
    
                ResultSet res = null;
                res = statement.executeQuery();
    
                while (res.next()) {
                    int id = res.getInt("id");
                    String sname = res.getString("name");
                    int age = res.getInt("age");
                    String sex = res.getString("sex");
                    Date birthday = res.getDate("birthday");
                    System.out.println("id:" + id + "姓名:" + sname + " 年龄:" + age + " 性别:" + sex + " 生日:" + birthday);
                    Student student = new Student(id,sname,age,sex,birthday);
                    studentList.add(student);
                }
    
            } catch (Exception e) {
                e.printStackTrace();
                System.out.println("连接数据库失败!");
            }
            return studentList;
        }
    }
    
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
     
    import android.app.Activity;
    import android.os.AsyncTask;
    import android.os.Bundle;
    import android.util.Log;
     
     
    public class MainActivity extends Activity 
    {
        
        private String UserName = "sa";
        private String Password = "sa";
        
        @Override
        public void onCreate(Bundle savedInstanceState)
        {
            super.onCreate(savedInstanceState);
            setContentView(R.layout.main);
            
            ConnectTask dt = new ConnectTask();
            dt.execute();
     
        }
        
        class ConnectTask extends AsyncTask<Integer, Integer, String>
        {
            Connection con = null;
            @Override
            protected void onPreExecute() {
                //第一个执行方法
                super.onPreExecute();
            }
            
            @Override
            protected String doInBackground(Integer... params) {            
                //建立于数据库的连接 
                try {
                    Class.forName( "net.sourceforge.jtds.jdbc.Driver");
                    con = DriverManager.getConnection( "jdbc:jtds:sqlserver://10.0.2.2:1433/AndroidSample", UserName, Password);    //10.0.2.2是使用模拟器是用的本机(pc)的IP,androidSample是我的数据库名称
                    testConnection(con);//测试数据库连接
                } catch (ClassNotFoundException e1) {
                    // TODO Auto-generated catch block
                    e1.printStackTrace();
                    Log.e("Class.forName::ClassNotFoundException", e1.getMessage());
                }catch (SQLException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
                
                return "执行完毕";
            }
     
            @Override
            protected void onPostExecute(String result) {
                super.onPostExecute(result);
            }
            
            public void testConnection(Connection con) throws java.sql.SQLException {             
                try {    
                    String sql = "SELECT * FROM Seed.Person";//查询表名为“Seed.Person”的所有内容   
                    Statement stmt = con.createStatement();//创建Statement   
                    ResultSet rs = stmt.executeQuery(sql);//ResultSet类似Cursor   
                      
                    while (rs.next()) {//<CODE>ResultSet</CODE>最初指向第一行   
                        Log.e("&&&&&", rs.getString("NameChs"));
                        Log.e("&&&&&", rs.getString("OperateUserName"));                      
                    }    
                    rs.close();  
                    stmt.close();  
                } catch (SQLException e) {  
                    System.out.println(e.getMessage().toString());  
                } finally {  
                    if (con != null)  
                        try {  
                            con.close();  
                        } catch (SQLException e) {  
                        }  
                }  
            }   
        }
     
    }
    
    

    主要遇到了两个问题:

    1、ClassNotFound错误:如果jtds库都导入了,还有这个问题,可能是jtds版本的问题。我最初用的jtds-1,3,1错误,后来用的jtds-1.2.7后解决了;

    2、与数据库的连接涉及网络操作,不能直接写在OnCreate函数中,代码中单独定义了一个类,进行数据库的操作。

    使用时会遇到JDTS版本和JDK版本不匹配问题:

    J2SE 7 = 51 (0x33 hex),

    J2SE 6.0 = 50 (0x32 hex),
    J2SE 5.0 = 49 (0x31 hex),
    JDK 1.4 = 48 (0x30 hex),
    JDK 1.3 = 47 (0x2F hex),
    JDK 1.2 = 46 (0x2E hex),
    JDK 1.1 = 45 (0x2D hex).

    一般JDK7对应JTDS的1.3.x版本

    JDK6对应1.2.x版本

    相关文章

      网友评论

          本文标题:使用JTDS连接sqlserver数据库

          本文链接:https://www.haomeiwen.com/subject/piioultx.html