package javabean;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class conn {
public Connection conn = null;
public Statement stmt = null;
public ResultSet rs = null;
// ****************建立连接**********************
public static Connection getConnection() {
Connection conn = null;
try {
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
} catch (Exception e) {
}
try {
String path = "jdbc:sqlserver://127.0.0.1:1433;DatabaseName=user1";
String name = "sa";
String word = "123456";
conn = DriverManager.getConnection(path, name, word);
} catch (SQLException ee) {
ee.printStackTrace();
}
if (conn == null) {
System.err.println(
"警告: DbConnectionManager.getConnection() 获得数据库链接失败.\r\n\r\n链接类型:" );
}
return conn;
}
// ********************查询*********************
public ResultSet query(String sql) {
try {
conn = getConnection();
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
ResultSet.CONCUR_UPDATABLE);
rs = stmt.executeQuery(sql);
System.out.println("数据库查询成功!");
return rs;
}
catch (SQLException ex) {
System.err.println(ex.getMessage());
}
return rs;
}
// ******************添加/修改/删除*************************
public int update(String sql){
try {
conn = getConnection();
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
ResultSet.CONCUR_UPDATABLE);
System.out.println("更新成功");
return stmt.executeUpdate(sql);
} catch (Exception e) {
System.out.println(e.getMessage());
}
return 0;
}
public void close() throws Exception{
if(rs != null) rs.close();
if(stmt != null) stmt.close();
if(conn != null) conn.close();
}
public static void main(String args[]){
conn cn=new conn();
String sql="select * from Online_Examination ";
ResultSet rs1=cn.query("select*from Online_Examination");
// System.out.println("数据库连接成功!");
}}
------解决方案--------------------
你这是连SQL Server?