java連接數據庫的代碼

用這個類吧.好的話,給我加加分.

建網站原本是網站策劃師、網絡程序員、網頁設計師等，應用各種網絡程序開發技術和網頁設計技術配合操作的協同工作。成都創新互聯公司專業提供網站制作、網站設計,網頁設計,網站制作(企業站、自適應網站建設、電商門戶網站)等服務,從網站深度策劃、搜索引擎友好度優化到用戶體驗的提升,我們力求做到極致!

import java.sql.*;

/**

* @功能: 一個JDBC的本地化API連接類,封裝了數據操作方法,只用傳一個SQL語句即可

* @作者: 李開歡

* @日期: 2007/

*/

public class ConnectionDemo {

/*

* 這里可以將常量全部放入另一個類中,以方便修改

*/

private static Connection conn;

private static Statement ps;

private static ResultSet rs;

private static final String DRIVER = "com.microsoft.jdbc.sqlserver.SQLServerDriver";

private static final String URL = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=mydb";

private static final String USER ="sa";

private static final String PASS = "sa";

public ConnectionDemo() {

// TODO Auto-generated constructor stub

ConnectionDemo.getConnection();

}

public static Connection getConnection(){

System.out.println("連接中...");

try {

Class.forName(ConnectionDemo.DRIVER);

conn = DriverManager.getConnection(ConnectionDemo.URL, ConnectionDemo.USER, ConnectionDemo.PASS);

System.out.println("成功連接");

} catch (ClassNotFoundException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return conn;

}

public static Statement getStatement(String sql){

System.out.println("執行SQL語句中...");

try {

ps = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);

if(sql.substring(0, 6).equals("select")){

rs = ps.executeQuery(sql);

System.out.println("執行完查詢操作,結果已返回ResultSet集合");

}else if(sql.substring(0, 6).equals("delete")){

ps.executeUpdate(sql);

System.out.println("已執行完畢刪除操作");

}else if(sql.substring(0, 6).equals("insert")){

ps.executeUpdate(sql);

System.out.println("已執行完畢增加操作");

}else{

ps.executeUpdate(sql);

System.out.println("已執行完畢更新操作");

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return ps;

}

public static ResultSet getResultSet(){

System.out.println("查詢結果為:");

return rs;

}

public static void closeConnection(){

System.out.println("關閉連接中...");

try {

if (rs != null) {

rs.close();

System.out.println("已關閉ResultSet");

}

if (ps != null) {

ps.close();

System.out.println("已關閉Statement");

}

if (conn != null) {

conn.close();

System.out.println("已關閉Connection");

}

} catch (Exception e) {

// TODO: handle exception

}

}

public static void main(String[] args) {

// TODO Auto-generated method stub

ConnectionDemo.getConnection();

String sql = "delete from type where id = 1";

ConnectionDemo.getStatement(sql);

String sql2 = "insert into type values(1,'教學設備')";

ConnectionDemo.getStatement(sql2);

String sql1 = "select * from type";

ConnectionDemo.getStatement(sql1);

ResultSet rs = ConnectionDemo.getResultSet();

System.out.println("編號 "+"類 型");

try {

while(rs.next()){

System.out.print(" "+rs.getInt(1)+" ");

System.out.println(rs.getString(2));

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

ConnectionDemo.closeConnection();

}

}

java連接SQL數據庫

import java.sql.ResultSet; //都是導入一些下面需要用到的類

String ConnStr="jdbc:microsoft:sqlserver://WINJUE:1433;DatabaseName=library";//jdbc連接數據庫url

public sqlServer() {

try {

Class.forName(DBDriver).newInstance(); //加載SQLServer驅動程序,DBDriver是你上面的代碼;

conn=DriverManager.getConnection(ConnStr,"sa","sa"); //和數據庫建立連接,ConnStr里面的://WINJUE:1433;DatabaseName=library 分別是主機地址:端口號;你自己建的數據庫（database）

}

catch(SQLException e) { //捕獲SQL異常

System.out.println(e.getMessage()); //要是出現異常,捕獲到后,這句代碼會把異常的信息(出錯的原因之類的)打印出來。

}

catch(Exception e) { //捕獲異常,這個是總的,所以不能和上面的順序顛倒,先小到大,我連ORACLE和MYSQL,這個我通常不要,只須捕獲SQL異常就OL

System.out.println(e.getMessage());

}

}

public Connection getConn(){ //獲取連接方法

return conn;

}

public void insert(String sql) {//增刪改

try {

Statement stm=conn.createStatement(); 調用conn下的方法,創建Statement對象

stm.executeUpdate(sql);//調用Statement下的方法執行SQL語句

System.out.println("操作成功");

}

catch(Exception e){

System.out.println(e.getMessage()); //如上

}

}

public ResultSet query(String sql){ //查詢

try{

Statement stm=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);

rs=stm.executeQuery(sql); //如上

}

catch(Exception e){

System.out.println(e.getMessage());

}

return rs;

}

public static void main(String args[]){

sqlServer conn=new sqlServer(); //創建sqlServer,就是你上面的類,以便調用里面的方法

ResultSet rs=conn.query("select * from Orders"); //調用query方法,執行SQL語句后,把結果保存到結果集里

//conn.insert("delete from BookInfo where BookName =" +"\'悟空傳\'");

//conn.insert("insert into BookInfo (BookID,BookName,Author,KeyWord) values (14445678,'悟空傳','今何在','孫悟空')");

try{

while(rs.next()){ //循環,判斷結果集里的記錄,一條條往下走,是否還有下一條記錄,若是返回真,繼續走

System.out.print(rs.getString("OrderID"));

//System.out.print(rs.getString("U_age"));

}

rs.close() ; //關閉結果集

}

catch (Exception e){

System.out.println(e.getMessage());

}

}

}

注:

TYPE_FORWARD_ONLY：缺省類型。只允許向前訪問一次，并且不會受到其他用戶對該數據庫所作更改的影響。

TYPE_SCROLL_INSENSITIVE：允許在列表中向前或向后移動，甚至能進行特定定位，例如移至列表中的第四個記錄或從當前位置向后移動兩個記錄。不會受到其他用戶對該數據庫所作更改的影響。

TYPE_SCROLL_SENSITIVE：象 TYPE_SCROLL_INSENSITIVE 相同，允許在記錄中定位。這種類型受到其他用戶所作更改的影響。如果用戶在執行完查詢之后刪除一個記錄，那個記錄將從 ResultSet 中消失。類似的，對數據值的更改也將反映在 ResultSet 中。

java中怎么連接sql數據庫

java中使用jdbc連接sql server數據庫步驟：

1.JDBC連接SQL Server的驅動安裝 ,前兩個是屬于數據庫軟件,正常安裝即可(注意數據庫登陸不要使用windows驗證)

1 將JDBC解壓縮到任意位置,比如解壓到C盤program files下面,并在安裝目錄里找到sqljdbc.jar文件,得到其路徑開始配置環境變量

在環境變量classpath 后面追加 C:\Program Files\Microsoft SQL Server2005 JDBC Driver\sqljdbc_1.2\enu\sqljdbc.jar

2 設置SQLEXPRESS服務器:

a.打開SQL Server Configuration Manager - SQLEXPRESS的協議 - TCP/IP

b.右鍵單擊啟動TCP/IP

c.雙擊進入屬性,把IP地址中的IP all中的TCP端口設置為1433

d.重新啟動SQL Server 2005服務中的SQLEXPRESS服務器

e.關閉SQL Server Configuration Manager

3 打開 SQL Server Management Studio,連接SQLEXPRESS服務器, 新建數據庫,起名字為sample

4 打開Eclipse

a.新建工程- Java - Java project,起名為Test

b.選擇eclipse-窗口-首選項-Java-installed JRE 編輯已經安裝好的jdk,查找目錄添加sqljdbc.jar

c.右鍵單擊目錄窗口中的Test, 選擇Build Path -Configure Build Path..., 添加擴展jar文件,即把sqljdbc.jar添加到其中

5 編寫Java代碼來測試JDBC連接SQL Server數據庫

怎么用java連接SQL數據庫？

如何用java連接sql的數據庫 1、java數據庫操作基本流程 : java數據庫操作基本流程：取得數據庫連接 - 執行sql語句 - 處理執行結果 - 釋放數據庫連接

2、幾個常用的重要技巧：可滾動、更新的記錄集 、 批量更新 、事務處理1、取得數據庫連接1）用DriverManager取數據庫連接例子：String className,url,uid,pwd;

className = "oracle.jdbc.driver.OracleDriver";

url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr;

uid = "system";

pwd = "manager";

Class.forName(className);

Connection cn = DriverManager.getConnection(url,uid,pwd);2）用jndi(java的命名和目錄服務)方式例子String jndi = "jdbc/db";

Context ctx = (Context) new InitialContext().lookup("java:comp/env");

DataSource ds = (DataSource) ctx.lookup(jndi);

Connection cn = ds.getConnection(); //多用于jsp中2、執行sql語句1）用Statement來執行sql語句String sql;

Statement sm = cn.createStatement();

sm.executeQuery(sql); // 執行數據查詢語句（select）

sm.executeUpdate(sql); // 執行數據更新語句（delete、update、insert、drop等）statement.close();2）用PreparedStatement來執行sql語句String sql;

sql = "insert into user (id,name) values (?,?)";

PreparedStatement ps = cn.prepareStatement(sql);

ps.setInt(1,xxx);

ps.setString(2,xxx);

...

ResultSet rs = ps.executeQuery(); // 查詢

int c = ps.executeUpdate(); // 更新3、處理執行結果查詢語句，返回記錄集ResultSet。更新語句，返回數字，表示該更新影響的記錄數。ResultSet的方法：1、next()，將游標往后移動一行，如果成功返回true；否則返回false。2、getInt("id")或getSting("name")，返回當前游標下某個字段的值。3、釋放連接。cn.close();一般，先關閉ResultSet，然后關閉Statement（或者PreparedStatement）；最后關閉Connection可滾動、更新的記錄集1、創建可滾動、更新的StatementStatement sm=cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,

ResultSet.CONCUR_READ_ONLY);該Statement取得的ResultSet就是可滾動的2、創建PreparedStatement時指定參數PreparedStatemet ps=cn.prepareStatement(sql,

ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);ResultSet.absolute(9000);批量更新1、StatementStatement sm = cn.createStatement();

sm.addBatch(sql1);

sm.addBatch(sql2);

...

sm.executeBatch()一個Statement對象，可以執行多個sql語句以后，批量更新。這多個語句可以是delete、update、insert等或兼有2、PreparedStatementPreparedStatement ps = cn.preparedStatement(sql);

{

ps.setXXX(1,xxx);

...

ps.addBatch();

}

ps.executeBatch();一個PreparedStatement，可以把一個sql語句，變換參數多次執行，一次更新。事務的處理1、關閉Connection的自動提交cn.setAutoCommit(false);2、執行一系列sql語句要點：執行每一個新的sql語句前，上一次執行sql語句的Statement（或者PreparedStatemet）必須先closeStatement sm ;

sm = cn.createStatement(insert into user...);

sm.executeUpdate();

sm.close();sm = cn.createStatement("insert into corp...);

sm.executeUpdate();

sm.close();3、提交cn.commit();