100分求javabean连接sql2000的源码，要求完全正确，在线等，符合要求，立刻结帖

Question

import java.sql.*;public class SMSConn { private static String server = new String();
private static String port = new String("1433");
private static String user = new String();
private static String pwd = new String();
    public String getServer() {
        return server;
    }
    public void setServer(String server) {
        this.server = server;
    }
    public String getPort() {
        return port;
    }
    public void setPort(String port) {
        this.port = port;
    }    
    public String getUser() {
        return user;
    }
    public void setUser(String user) {
        this.user = user;
    }
    public String getPwd() {
        return pwd;
    }
    public void setPwd(String pwd) {
        this.pwd = pwd;
    }
    
public static Connection getMSSQLCn() {
Connection cn = null;
try {
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
cn = DriverManager.getConnection("jdbc:microsoft:sqlserver://"
+ server + ":" + port,user,pwd); 
} catch(Exception e) { }
return cn;
}
/*
public static void main(String[] args) {
SMSConn smsconn = new SMSConn();
smsconn.setServer("lintao");
//smsconn.setPort("1433");
smsconn.setUser("sa");
smsconn.setPwd("");
Connection conn = smsconn.getMSSQLCn();
}
*/}

Answer 1

package servletbean;import java.awt.*;
import javax.swing.JPanel;
import java.sql.*;public class MyBean extends JPanel
{
    protected Connection conn = null;
    protected Statement MyState = null;
    protected ResultSet Result;
    public MyBean()
    {
        super();
    }    public void executesql()
    {
      try{
  Class.forName("sun.jdbc.odbc.JdbcOdbcDriver").newInstance();
  conn = DriverManager.getConnection("jdbc:odbc:MYDB","usename","pass");
 MyState = conn.createStatement();
 String sql = "select * from class";
ResultSet rs = MyState.executeQuery(sql);
setResult(rs);
}catch(SQLException e){
}catch(ClassNotFountException e1){
}catch(InstantiationExecption e2){
}
    }    public java.sql.ResultSet getResult()
    {
        return Result;
    }    public void setResult(java.sql.ResultSet newResult)
    {
        Result = newResult;
    }    public void Sqlclose()
    {
try{
conn.close();
}catch(SQLExecption e){
}
}
}
在你的机子上也许不对，你自己调下，代码百分百对，用servlet调用

Answer 2

package mypackage;import java.sql.*;public class DataBaseBean
{
private String databasename = "LunTan";
private String username = "sa";
private String password = ""; static Connection conn = null;
Statement stmt = null;
ResultSet rs = null;

public DataBaseBean() {} public void setDatabasename(String d)
{
databasename = d;
} public String getDatabasename()
{
return databasename;
} public void setUsername(String u)
{
username = u;
} public String getUsername()
{
return username;
} public void setPassword(String p)
{
password = p;
} public String getPassword()
{
return password;
} public void openConnection()
{
try
{
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
String url="jdbc:microsoft:sqlserver://127.0.0.1;databasename=" + databasename;
// Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
// String url = "jdbc:odbc:driver={Microsoft Access Driver (*.mdb)};DBQ=C:\\myweb\\Data\\liuyan.mdb"";
// setUsername("Admin");
conn = DriverManager.getConnection(url, username, password);
}   
catch (java.lang.ClassNotFoundException e)
{
e.printStackTrace();
}
catch (java.sql.SQLException e)
{
e.printStackTrace();
}
} public void closeConnection()
{
try
{
if (rs != null)
{
rs.close();
}
if (stmt != null)
{
stmt.close();
}
if (conn != null)
{
conn.close();
}
}
catch (java.sql.SQLException e)
{
e.printStackTrace();
}
rs = null;
stmt = null;
conn = null;
} public ResultSet executeQuery(String sql)
{
try
{
if (conn == null)
{
openConnection();
}
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
rs = stmt.executeQuery(sql);
}
catch (SQLException e)
{
e.printStackTrace();
}
return rs;
} public boolean executeUpdate(String sql)
{
boolean bupdate = false; try
{
if (conn == null)
{
openConnection();
}
stmt = conn.createStatement();
int rowCount = stmt.executeUpdate(sql);
if (rowCount != 0)
{
bupdate = true;
}
}
catch (SQLException e)
{
e.printStackTrace();
}
return bupdate;
}
}

Answer 3

import java.sql.*;public class SMSConn { private static String server = new String();
private static String port = new String("1433");
private static String user = new String();
private static String pwd = new String();
    public String getServer() {
        return server;
    }
    public void setServer(String server) {
        this.server = server;
    }
    public String getPort() {
        return port;
    }
    public void setPort(String port) {
        this.port = port;
    }    
    public String getUser() {
        return user;
    }
    public void setUser(String user) {
        this.user = user;
    }
    public String getPwd() {
        return pwd;
    }
    public void setPwd(String pwd) {
        this.pwd = pwd;
    }
    
public static Connection getMSSQLCn() {
Connection cn = null;
try {
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
cn = DriverManager.getConnection("jdbc:microsoft:sqlserver://"
+ server + ":" + port,user,pwd); 
} catch(Exception e) { }
return cn;
}
/*
public static void main(String[] args) {
SMSConn smsconn = new SMSConn();
smsconn.setServer("lintao");
//smsconn.setPort("1433");
smsconn.setUser("sa");
smsconn.setPwd("");
Connection conn = smsconn.getMSSQLCn();
}
*/}

Answer 4

package com.database;import java.sql.*;
import java.io.*;
import java.lang.*;
public class MydbBean
{
private Statement st=null;
private ResultSet rs=null;
private Connection con=null;
//构造函数
public MydbBean()
{}
//根据dsn参数，加载数据库驱动,建立连接
public void OpenConn(String dsn,String id,String pwd) 
throws Exception
{
try
{
dsn="jdbc:odbc:"+dsn;
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
con=DriverManager.getConnection(dsn,id,pwd);
}catch(SQLException e)
{
System.err.println("execute sql error"+e.getMessage());
}
}

//执行查询类的sql语句，又返回集
public ResultSet executeQuery(String strSQL)
{
rs=null;
try
{
st=con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
rs=st.executeQuery(strSQL);


}catch(SQLException e)
{
System.err.println("Query sql error"+e.getMessage());
}
return rs;
}

//执行跟新类的sql 语句，午返回值
public void executeUpdate(String strSQL)
{
st=null;
rs=null;
try
{
st=con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
st.executeUpdate(strSQL);
st.close();
con.close();
}catch(SQLException e)
{
 System.err.println("Update sql error"+e.getMessage());
 
}
}
//关闭对象
public void closeSt()
{
try
{
st.close();
}catch(SQLException e)
{
 System.err.println("close sql error"+e.getMessage());
 
}
}
//关闭连接
public void closeCon()
{
try
{
con.close();
}catch(SQLException e)
{
 System.err.println("close sql error"+e.getMessage());
 
}
}
}