java如何连接SQLsever,具体点谢谢最近要做一个课程设计,但是我不会连接数据库怎么配置数据源?怎么使用语句

解决方案 »

  1.   


    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;public class DBHandle { public static Connection getConnection(){
    Connection conn = null;
    String driverClassName = "net.sourceforge.jtds.jdbc.Driver";
    String url = "jdbc:jtds:sqlserver://localhost:1433;databaseName=pubs;user=sa";

    try {
    Class.forName(driverClassName);
    conn = DriverManager.getConnection(url);
    } catch (ClassNotFoundException e) {
    // TODO 自动生成 catch 块
    e.printStackTrace();
    } catch (SQLException e) {
    // TODO 自动生成 catch 块
    e.printStackTrace();
    }
    return conn;
    }

    public static void closeConnection(Connection conn){
    try {
    conn.close();
    } catch (SQLException e) {
    // TODO 自动生成 catch 块
    e.printStackTrace();
    }
    }

    public static void closePreparedStatement(PreparedStatement ps){
    try {
    ps.close();
    } catch (SQLException e) {
    // TODO 自动生成 catch 块
    e.printStackTrace();
    }
    }

    public static void closeResultSet(ResultSet rs){
    try {
    rs.close();
    } catch (SQLException e) {
    // TODO 自动生成 catch 块
    e.printStackTrace();
    }
    }

    }
      

  2.   


    package com.shy.sql;import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.SQLException;/**
     * 
     * @author shy.qiu
     *
     */
    public class JdbcUtils {    private static ThreadLocal threadConnection = new ThreadLocal();
        //private static ThreadLocal threadTransaction = new ThreadLocal();    /**
         * 连接MsSql数据库
         * @return
         */
        public static Connection getMsConnection(){
            Connection conn = null;
            String url = null;
            
            try{
                Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
                url = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=test";
                conn = DriverManager.getConnection(url,"sa","");            if( conn==null ){
                    throw new SQLException("Can't connect MsSql!");
                }
                
            } catch (ClassNotFoundException e2) {
                e2.printStackTrace();
            }catch(SQLException e){
                System.out.println("url:"+url);     
                e.printStackTrace();
            }
            return conn;    
        }
            /**
         * 连接MsSql数据库
         * @return
         */
        public static Connection getMySqlConnection(){
            Connection conn = null;
            String url = null;
            
            try{
                Class.forName("com.mysql.jdbc.Driver");
                url = "jdbc:mysql://localhost:3306/ShopOnline";
                conn = DriverManager.getConnection(url,"root","123321");            if( conn==null ){
                    throw new SQLException("Can't connect MsSql!");
                }
                
            } catch (ClassNotFoundException e2) {
                e2.printStackTrace();
            }catch(SQLException e){
                System.out.println("url:"+url);     
                e.printStackTrace();
            }
            return conn;    
        }
        
        /**
         * 获取当前Connection
         * @return
         * @throws SQLException
         */
        public static Connection getCurrentConnection() throws SQLException{
            Connection conn = (Connection) threadConnection.get();
            if (conn == null) {
                System.out.println("Opening new conncetion  for this threadConnection.");
                conn = getMySqlConnection();
                threadConnection.set(conn);
            }
            return conn;
        }    /**
         * 获取当前Connection
         * @return
         * @throws SQLException
         */
        public static Connection getCurrentConnection( boolean isTransaction ) throws SQLException{
            Connection conn = getCurrentConnection();
            
            //启动事物
            if( isTransaction ){
                conn.setAutoCommit(false);
            }
            
            return conn;
        }
        
        /**
         * 关闭当前Connection,并提交事物
         * @throws SQLException
         */
        public static void closeCurrentConnection(){
            try{
                Connection conn = (Connection) threadConnection.get();
                threadConnection.set(null);
                if( conn!=null ){
                 conn.close();
                }
            }catch(SQLException e){
                e.printStackTrace();
            }
        }
        
        /**
         * 关闭指定的数据库链接
         * @param conn
         * @throws SQLException
         */
        public static void closeConnection( Connection conn ) throws SQLException{
            try{
                if( conn!=null ){
                    conn.close();
                }
            }catch(SQLException e){
                e.printStackTrace();
            }
        }
            /*******************************************************
         * Transaction操作方法
         *******************************************************/
        
        /**
         * 开始一个新事务
         */
        public static void beginTransaction(){
            try{
                getCurrentConnection().setAutoCommit(false);
            }catch(SQLException e){
                e.printStackTrace();
            }
        }
        
        /**
         * 提交数据库的事务
         * @throws SQLException
         */
        public static void commitTransaction(){
            try{
                getCurrentConnection().commit();
            }catch(SQLException e){
                e.printStackTrace();
            }
        }
        
        /**
         * 回滚当前事务方法的实现
         * @throws SQLException
         */
        public static void rollbackTransaction(){
            try{
                getCurrentConnection().rollback();
            }catch(SQLException e){
                e.printStackTrace();
            }
        }
        
    }
      

  3.   

    最近我也在寻求这个问题,会连接access但是不会连接sql……