日期:2014-05-20 浏览次数:20844 次
package lihan; import java.sql.*; public class SqlConn { public Statement getSt(){ Statement st=null; try { Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver"); Connection con=DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=shop","sa","sa"); st=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY); return st; } catch (Exception e) { // TODO 自动生成 catch 块 e.printStackTrace(); } return st; } }
------解决方案--------------------
用JAVA连接数据库主要有两种方式,
一是用JDBC-ODBC桥来连接,二是用相关厂商提供的相应驱动程序来连接,首先谈谈第一种连接。
JDBC-ODBC桥接器是用JdbcOdbc.Class和一个用于访问ODBC驱动程序的本地库实现的。对于WINDOWS平台,该本地库是一个动态连接库DLL(JDBCODBC.DLL)。
由于JDBC在设计上与ODBC很接近。在内部,这个驱动程序把JDBC的方法映射到ODBC调用上,这样,JDBC就可以和任何可用的ODBC驱动程序进行交互了。这种桥接器的优点是,它使JDBC目前有能力访问几乎所有的数据库。通行方式如图所示:
应用程序---JDBC API---JDBC-ODBC---ODBC API---ODBC层---数据源
具体操作方法为:
首先打开控制面板的管理工具,打开数据源(ODBC),在用户DSN里面添加数据源(即你要连接的数据库的名字),在这里假定连接SQL SERVER 2000的GoodsSupply数据库。名称填写你要连接的数据库的名称(GoodsSupply),然后逐步设置,如果选用了使用SQL-SERVER密码认证的话,就要输入相应的用户名及密码连接到数据库。一路下一步设置完成。
在JAVA里面编写程序进行测试,在这里我的程序是让用户输入任意的表名与与列名,把该列的所有数据输出。源代码如下:
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.sql.*;
public class ODBCBridge {
public static void main(String[] args) {
String url="jdbc:odbc:GoodsSupply";
Statement sm=null;
String command=null;
ResultSet rs=null;
String tableName=null;
String cName=null;
String result=null;
BufferedReader input=new BufferedReader(new InputStreamReader(System.in));
try {
try {
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver"); //加载驱动
}catch(ClassNotFoundException e){
System.out.println("Can not load Jdbc-Odbc Bridge Driver");
System.err.print("ClassNotFoundException:");
System.err.println(e.getMessage());
}
Connection con=DriverManager.getConnection(url,"USER","PASSWORD"); //使用SQL-SERVER2000认证
DatabaseMetaData dmd=con.getMetaData(); //DMD为连接的相应情况
System.out.println("连接的数据库:"+dmd.getURL());
System.out.println("驱动程序:"+dmd.getDriverName());
sm=con.createStatement();
System.out.println("输入表名");
tableName=input.readLine();
while(true) {
System.out.println("输入列名(为空时程序结束):");
cName=input.readLine();
if(cName.equalsIgnoreCase(""))
break;
command="select "+cName+" from "+tableName;
rs=sm.executeQuery(command); //执行查询
if(!rs.next())
System.out.println("表名或列名输入有误");
else {
System.out.println("查询结果为:");
do
{
result=rs.getString(cName);
//数据库语言设置为中文,不用转换编码
//result=new String(result.getBytes("ISO-8859-1"),"GB2312");
System.out.println(result);
}while(rs.next());
}
}
}catch(SQLException ex) {
System.out.println("SQLException:");
while(ex!=null) {
System.out.println("Message:"+ex.getMessage());
ex=ex.getNextException();
}
}catch(Exception e) {
System.out.println("IOException");
}
}
}
------解决方案--------------------
// 其中需要导入一些包,加载驱动包,处理异常等等。 // 数据库连接对象 class DBConnection { private final static String DRIVER = "com.microsoft.jdbc.sqlserver.SQLServerDriver"; // 驱动字符串 private final static String URL = "jdbc:microsoft:sqlserver://"; // 连接字符串 private final static String HOST = "localhost"; // 连接到的主机 private final static String PORT = "1433"; // 端口号 private final static String DBNAME = "myDb"; // 数据库名称 private final static String USER = "sa"; // 数据库用户名 private final static String PASSWORD = ""; // 数据库密码 // 建立与数据库的连接 public Connection getConnection() throws SQLException { return DriverManager.getConnection(URL + HOST + ":" + PORT + ";databaseName=" + DBNAME, USER, PASSWORD); } } // 对数据库的操作 class DBOperation { // 创造一个连接对象 private DBConnection dbc = new DBConnection(); // 加载数据库驱动程序 static { try { Class.forName(DRIVER); } catch(Exception ex){ System.err.prinitln(ex.getMessage()); } } // 利用dbc对象执行增、删、改和查操作 // ... } // 测试类 public class DBTest { public static void main(String[] args) { DBOperation dbo = new DBOperation(); // 调用其中定义的增、删、改和查方法执行功能 } }