java如何连接SQLsever,具体点谢谢最近要做一个课程设计,但是我不会连接数据库怎么配置数据源?怎么使用语句
解决方案 »
- 多线程设置表模型(DefaultTableModel),出现异常
- 请教一个J2SE入门的问题
- java.nio 接受请求时ClassCastException 异常
- 初试过了 后天复试 公司是做游戏的 用java作里面的一些模块 一般都用java作什么模块啊? 大家给点例子 越多越好
- 【新手提问】关于InputStreamReader控制台输入出现?号的问题
- 问一个JDK文档中的Throws问题
- 【求助】有关BufferesStream流中 读写是否需要刷新缓冲区的问题
- 查看java程序运行过程的工具?
- tomcat以配好,declaration.jsp如何在tomcat上运行?
- 怎么不能获得JFormattedTextField框中的值?
- 求数据结构(java版)习题答案
- 空链表
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();
}
}
}
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();
}
}
}