您的位置:首页 > 编程语言 > Java开发

Java如何连接SQLserver 2008数据库

2015-10-05 17:19 567 查看
package com.dao;
//导入相关包
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
*
* @author Samuel
*/
/*数据库操作类*/
public class Zhi_Dao {

protected static String dbClassName = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
//注意修改数据库名称
protected static String dbUrl = "jdbc:sqlserver://localhost:1434;DatabaseName=jiudian";
//数据库用户名保存在变量dbUser中
protected static String dbUser = "sa";
//数据库密码保存在dbPwd中
protected static String dbPwd = "123456";
protected static String second = null;
private static Connection conn = null;
//Dao类的构造方法
private Zhi_Dao() {
try {
if (conn == null) {
//加载驱动
Class.forName(dbClassName);
//连接数据库
conn = DriverManager.getConnection(dbUrl, dbUser, dbPwd);
} else {
return;
}
System.out.println("conn成功!");//控制台打印显示连接成功
} catch (Exception ee) {
ee.printStackTrace();
}

}
/*数据库查询方法
* 方法参数:sql查询语句
* 返回值:查询返回的结果集
*/
private static ResultSet executeQuery(String sql) {
try {
if (conn == null) {
new Zhi_Dao();
}
//下面一行调用了Statement类的executeQuery(String sql)方法
//执行给定的 SQL 语句,该语句返回单个 ResultSet 对象,绝大多数是用SELECT语句
return conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE).executeQuery(sql);
} catch (SQLException e) {
e.printStackTrace();
return null;
} finally {
}
}
/*数据库更新方法
* 方法参数:sql更新语句
* 返回值:一个整数,指示受影响的行数(即更新计数)
*/
private static int executeUpdate(String sql) {

try {
if (conn == null) {
new Zhi_Dao();
}
//下面一行调用了Statement类中的executeUpdate方法
//用于执行 INSERT、UPDATE 或 DELETE 语句以及 SQL DDL(数据定义语言)语句
return conn.createStatement().executeUpdate(sql);
} catch (SQLException e) {
System.out.println(e.getMessage());
return -1;
} finally {
}
}
/**************************下面是针对当前项目定义的方法*************************************/
public static boolean loginResult(String ph, String password) {
//在当前数据库中的information表中查询
String sql = "select *  from information where 手机号='" + ph
+ "' and 密码='" + password + "'";
//返回的结果,包括所有的用户密码(ph和password)注册信息
ResultSet rs = Zhi_Dao.executeQuery(sql);
boolean loginR = false;
try {
//从当前结果集rs中取得需要的信息,并进行比较核对
while (rs.next()) {
String phGet = rs.getString("手机号");
String passwordGet = rs.getString("密码");
//判断
if (phGet.equals(ph) && passwordGet.equals(password)) {
loginR = true;
break;//跳出当前循环
}
}
} catch (SQLException ex) {
Logger.getLogger(Zhi_Dao.class.getName()).log(Level.SEVERE, null, ex);
}
Zhi_Dao.close();
return loginR;
}

//预订支付
public static boolean zfResult(String ph, String password) {
//在当前数据库中的alipay表中查询
String sql = "select *  from alipay where 账户名='" + ph
+ "' and 密码='" + password + "'";
//返回的结果,包括所有的用户密码(name和password)注册信息
ResultSet rs = Zhi_Dao.executeQuery(sql);
boolean loginR = false;
try {
//从当前结果集rs中取得需要的信息,并进行比较核对
while (rs.next()) {
String phGet = rs.getString("账户名");
String passwordGet = rs.getString("密码");

if (phGet.equals(ph) && passwordGet.equals(password)) {
loginR = true;
break;//跳出当前循环
}
}
} catch (SQLException ex) {
Logger.getLogger(Zhi_Dao.class.getName()).log(Level.SEVERE, null, ex);
}
Zhi_Dao.close();
return loginR;
}
/************************记得关闭连接通道*************************************/
public static void close() {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
} finally {
conn = null;
}
}
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: