(一)mysql连接
//加载数据库驱动 Class.forName("com.mysql.jdbc.Driver").newInstance(); String url="jdbc:mysql://localhost/数据库名?user=root&password=密码"; //得到连接 Connection ct=DriverManager.getConnection(url); //创建statement Statement sm=ct.createStatement(); //执行查寻操作 ResultSet rs=sm.executeQuery("sql查询句子");(二) mssql的连接方式 当驱动包为: msbase.jar mssqlserver.jar msutil.jar 数据库驱动写法为: com.microsoft.jdbc.sqlserver.SQLServerDriver url写法为: jdbc:microsoft:sqlserver://localhost:1433;databaseName=数据库 连接实现 Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance(); String url="jdbc:microsoft:sqlserver://localhost:1433;databaseName=db_name"; String userName = "sa"; String password="密码"; Connection con=DriverManager.getConnection(url,userName,password); Statement stmt=con.createStatement(); 另一种
当驱动包为:
jtds-0.8.0.jar 是 数据库驱动写法为:net.sourceforge.jtds.jdbc.Driver url的写法为:jdbc:jtds:sqlserver://localhost:1433/数据库名字 连接实现Class.forName("net.sourceforge.jtds.jdbc.Driver").newInstance(); //加载sql server驱动
String url="jdbc:jtds:sqlserver://localhost:1433/数据库名字"; //url地址 String userName = "sa"; //登陆用户名 String password="密码"; //登录密码 Connection con=DriverManager.getConnection(url,userName,password); //得到连接 Statement stmt=con.createStatement(); 或是 Class.forName("net.sourceforge.jtds.jdbc.Driver"); String url="jdbc:jtds:sqlserver://localhost:1433/数据库名字"; Connection con=DriverManager.getConnection(url,"sa","密码"); Statement stmt=con.createStatement(); (三) 当然我们也可以写一个java类文件作为公共类,这样我们在调用的时候就方便多了package com.heise;
import java.sql.*;
public class JDBConnection {
private final String dbDriver="net.sourceforge.jtds.jdbc.Driver";//sql驱动 private final String url="jdbc:jtds:sqlserver://localhost:1433/数据库名字";//url地址 private final String userName="sa";//登录名字 private final String password="密码";//登录密码 private Connection conn=null; //取得数据库连接的类对象 public JDBConnection() { try{//加载驱动 Class.forName(dbDriver).newInstance(); }catch(Exception e) { System.out.println("数据库加载失败"); } } //创建连接 public boolean createConnection() { try{ conn=DriverManager.getConnection(url,userName,password); conn.setAutoCommit(true); }catch(SQLException e) { } return true; } // 对数据库的增加、修改和删除的操作 public boolean executeUpdate(String sql) {if (conn == null) {
createConnection(); } try { Statement stmt = conn.createStatement(); int iCount = stmt.executeUpdate(sql); System.out.println("操作成功,所影响的记录数为" + String.valueOf(iCount)); } catch (SQLException e) {}
return true; } //对数据库的查询 public ResultSet executeQuery(String sql) { ResultSet rs; try{ if(conn==null) { createConnection(); } Statement stmt=conn.createStatement(); rs=stmt.executeQuery(sql); }catch(SQLException e) { return null; } return rs; } //关闭数据库连接 public void close() { try{ if(conn!=null) { conn.close(); } }catch(SQLException e) { e.printStackTrace(); }finally{ conn=null; } } }