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連接起來啊

這個是連接sql server 2000的數據庫的

package com.bling.sql1;

import java.sql.*;

public class SqlTest

{

private String drive="com.microsoft.jdbc.sqlserver.SQLServerDriver";

private String url="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=BLing";

private String user="sa";

private String pass="84004880";

private Connection connect;

private Statement state;

private ResultSet result;

public SqlTest()

{

try

{

Class.forName(drive);

connect=DriverManager.getConnection(url,user,pass);

state=connect.createStatement();

result=state.executeQuery("select * from Blingkk");

while(result.next())

{

System.out.println(result.getString("username"));

System.out.println(result.getString("password"));

}

state.close();

connect.close();

}

catch (Exception e)

{

e.printStackTrace();

}

}

public static void main(String[] args)

{

new SqlTest();

}

}

求JAVA連接SQL數據庫的代碼

package com.conn;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.Statement;

import java.util.HashMap;

import java.util.Map;

public class ConPool {

private String strDriverClass;

private String strJdbcUrl;

private String strUserName;

private String strUserPwd;

public ConPool(){

}

public Connection getMyJdbcConn()

{

Connection myConn=null;

try {

Class.forName(this.getStrDriverClass()).newInstance();

//DriverManager.registerDriver (new org.postgresql.Driver());

myConn= DriverManager.getConnection(this.getStrJdbcUrl(),this.getStrUserName(),this.getStrUserPwd());

}catch (Exception ex) {

System.out.print(ex);

}

return myConn;

}

public void closeConn(Connection myConn)

{

if (myConn!=null) {

try{

myConn.close();

myConn=null;

}catch(Exception e){}

}

}

/**

* @return the strDriverClass

*/

public String getStrDriverClass() {

return strDriverClass;

}

/**

* @param strDriverClass the strDriverClass to set

*/

public void setStrDriverClass(String strDriverClass) {

this.strDriverClass = strDriverClass;

}

/**

* @return the strJdbcUrl

*/

public String getStrJdbcUrl() {

return strJdbcUrl;

}

/**

* @param strJdbcUrl the strJdbcUrl to set

*/

public void setStrJdbcUrl(String strJdbcUrl) {

this.strJdbcUrl = strJdbcUrl;

}

/**

* @return the strUserName

*/

public String getStrUserName() {

return strUserName;

}

/**

* @param strUserName the strUserName to set

*/

public void setStrUserName(String strUserName) {

this.strUserName = strUserName;

}

/**

* @return the strUserPwd

*/

public String getStrUserPwd() {

return strUserPwd;

}

/**

* @param strUserPwd the strUserPwd to set

*/

public void setStrUserPwd(String strUserPwd) {

this.strUserPwd = strUserPwd;

}

public static void main(String[] args) {

Connection crmCon=null;

ConPool cp = new ConPool();

// //MySQL數據庫

// cp.setStrDriverClass("com.mysql.jdbc.Driver");

// cp.setStrJdbcUrl("jdbc:mysql://127.0.0.1:3306/test?useUnicode=truecharacterEncoding=gbk");

// cp.setStrUserName("test");

// cp.setStrUserPwd("test");

//postgre數據庫

cp.setStrDriverClass("org.postgresql.Driver");

cp.setStrJdbcUrl("jdbc:postgresql://127.0.0.1:5432/test");

cp.setStrUserName("test");

cp.setStrUserPwd("test");

crmCon=cp.getMyJdbcConn();

if (crmCon!=null) {

System.out.println("通過jdbc連接成功！");

}

// try {

// Statement stmtCrmUpd = crmCon.createStatement();

//

// stmtCrmUpd.addBatch("truncate table trade.sms_tmp_feild ");

// stmtCrmUpd.addBatch("INSERT INTO trade.sms_tmp_feild VALUES (0, 'membername', '%s', '會員姓名')");

// stmtCrmUpd.addBatch("INSERT INTO trade.sms_tmp_feild VALUES (1, 'cardwh', '%s', '卡號末四位')");

// stmtCrmUpd.addBatch("INSERT INTO trade.sms_tmp_feild VALUES (2, 'transmerchant', '%s', '交易店')");

// stmtCrmUpd.addBatch("INSERT INTO trade.sms_tmp_feild VALUES (3, 'transtype', '%s', '交易類型')");

// stmtCrmUpd.addBatch("INSERT INTO trade.sms_tmp_feild VALUES (4, 'transamount', '%.2f', '交易金額')");

// stmtCrmUpd.addBatch("INSERT INTO trade.sms_tmp_feild VALUES (5, 'cardbalance', '%.2f', '卡余額')");

// stmtCrmUpd.addBatch("INSERT INTO trade.sms_tmp_feild VALUES (6, 'merchantbrand', '%s', '交易商戶集團名稱')");

// stmtCrmUpd.addBatch("INSERT INTO trade.sms_tmp_feild VALUES (7, 'couponname', '%s', '券名稱')");

// stmtCrmUpd.addBatch("INSERT INTO trade.sms_tmp_feild VALUES (9, 'cardno', '%s', '卡號')");

// stmtCrmUpd.addBatch("INSERT INTO trade.sms_tmp_feild VALUES (10, 'cardmerchant', '%s', '卡屬商戶名')");

// stmtCrmUpd.addBatch("INSERT INTO trade.sms_tmp_feild VALUES (11, 'transdate', '%tm月%te日', '交易日期')");

// stmtCrmUpd.addBatch("INSERT INTO trade.sms_tmp_feild VALUES (12, 'transtime', '%tT', '交易時間')");

//

// crmCon.setAutoCommit(false);

// //成功的話再提交保存當前最大ID號和失敗日志

// stmtCrmUpd.executeBatch();

// crmCon.commit();

// crmCon.setAutoCommit(true);

//

// }catch (Exception ex) {

// System.out.println("數據庫執行異常！");

// System.out.println(ex);

// try {

// crmCon.rollback();

// }catch (Exception e) {

// System.out.println("數據庫回滾異常！");

// System.out.println(e);

// }

// }

//

// ResultSet rset = null;

//

// String sql = "select field_name,field_type from trade.sms_tmp_feild";

// MapString,String m = new HashMapString,String();

// try {

// Statement stmtCrm = crmCon.createStatement();

// rset = stmtCrm.executeQuery(sql);

//

// if (rset!=null){

// while (rset.next()){

// m.put(rset.getString("field_name"), rset.getString("field_type"));

// }

// rset.close();

// }

// rset = null;

// stmtCrm.close();

// stmtCrm = null;

// }catch (Exception ex) {

// System.out.println("數據庫執行異常！");

// System.out.println(ex);

// }

//

//

// String strSql = "SELECT id,replace(replace(replace(replace(replace(replace(message_template,'tm月%te日',''),'d',''),'.2f',''),'tF',''),'tT',''),'s','') as message_template," +

// "template_feilds FROM trade.message_template";

//

// try {

// Statement stmtCrm = crmCon.createStatement();

// Statement stmtCrmUpd = crmCon.createStatement();

// rset = stmtCrm.executeQuery(strSql);

//

// if (rset!=null){

// while (rset.next()){

// if (rset.getString("template_feilds")!=nullrset.getString("message_template")!=null){

// String[] aryFeild = rset.getString("template_feilds").split(",");

// String[] aryCon = rset.getString("message_template").split("%");

// String tid = rset.getString("id");

//

// if (aryFeild!=nullaryFeild.length0aryCon!=nullaryCon.length0){

// StringBuilder strB = new StringBuilder();

// StringBuilder strF = new StringBuilder();

// StringBuilder bSql = new StringBuilder();

// strB.append(aryCon[0]);

// for (int i=1;iaryCon.length;i++){

// String strFormatCon = m.get(aryFeild[i-1]);

// if (strFormatCon.indexOf("%", 1)0){

// strF.append(aryFeild[i-1]+",");

// }

// strF.append(aryFeild[i-1]+",");

// strB.append(strFormatCon);

// strB.append(aryCon[i]);

// }

//

// if (strF.lastIndexOf(",")==strF.length()-1){

// strF.delete(strF.length()-1, strF.length());

// }

// System.out.println("原模板內容："+rset.getString("message_template"));

// System.out.println("新摸版內容："+strB.toString());

// System.out.println("原模板字段："+rset.getString("template_feilds"));

// System.out.println("新模板字段："+strF.toString());

//

// bSql.append("update trade.message_template set message_template='"+strB.toString()+"',template_feilds='"+strF.toString()+"' where id="+tid);

//

// System.out.println("修改模板Sql："+strF.toString());

//

// stmtCrmUpd.addBatch(bSql.toString());

// }

// }

// }

// rset.close();

// }

// rset = null;

// stmtCrm.close();

// stmtCrm = null;

//

// crmCon.setAutoCommit(false);

// stmtCrmUpd.executeBatch();

// crmCon.commit();

// crmCon.setAutoCommit(true);

//

// stmtCrmUpd.close();

// stmtCrmUpd = null;

// }catch (Exception ex) {

// System.out.println("數據庫執行異常！");

// System.out.println(ex);

// try {

// crmCon.rollback();

// }catch (Exception e) {

// System.out.println("數據庫回滾異常！");

// System.out.println(e);

// }

// }

cp.closeConn(crmCon);

}

}

java如何實現sql連接和查詢的代碼？

import java.sql.Connection。

import java.sql.DriverManager; ?

import java.sql.PreparedStatement; ?

import java.sql.ResultSet; ?

import java.sql.SQLException;

import javax.naming.Context; ?

import javax.naming.InitialContext; ?

import javax.naming.NamingException; ?

import javax.sql.DataSource;

public class DBCon {

//數據庫驅動對象

public static final String DRIVER="oracle.jdbc.driver.OracleDriver";

//數據庫連接地址(數據庫名)

public static final String URL="jdbc:oracle:thin:@localhost:1521:orcl";

//登陸名

public static final String USER="FM";

//登陸密碼

public static final String PWD="FM";

//創建數據庫連接對象

private Connection con=null;

//創建數據庫預編譯對象

private PreparedStatement ps=null;

//創建結果集

private ResultSet rs=null;

//創建數據源對象

public static DataSource source=null;

// ?//靜態代碼塊 ?

// ?static{ ?

// ?

// ? ? ?//初始化配置文件context ?

// ? ? ?try { ?

// ? ? ? ? ?Context context=new InitialContext(); ?

// ? ? ? ? ?source=(DataSource)context.lookup("java:comp/env/jdbc/webmessage"); ?

// ? ? ?} catch (Exception e) { ?

// ? ? ? ? ?// TODO Auto-generated catch block ?

// ? ? ? ? ?e.printStackTrace(); ?

// ? ? ?} ?

// ?

// ?

// ?}

/**

* 獲取數據庫連接

*/

public Connection getCon(){

try {

Class.forName(DRIVER);

} catch (ClassNotFoundException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

try {

con=DriverManager.getConnection(URL,USER,PWD);

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return con;

} ?

// ?/** ?

// ? * 獲取數據庫連接 ?

// ? */ ?

// ?public Connection getCon(){ ?

// ?

// ? ? ?try { ?

// ? ? ? ? ?con=source.getConnection(); ?

// ? ? ?} catch (SQLException e) { ?

// ? ? ? ? ?// TODO Auto-generated catch block ?

// ? ? ? ? ?e.printStackTrace(); ?

// ? ? ?} ?

// ?

// ? ? ?return con; ?

// ?} ?

/**

* 關閉所有資源

*/

public void closeAll(){

if(rs!=null)

try {

rs.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

if(ps!=null)

try {

ps.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

if(con!=null)

try {

con.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} ?

}

/**

* @param sql數據庫更新(增、刪、改) 語句

* @param pras參數列表（可傳，可不傳，不傳為NULL，以數組形式存在）

* @return 返回受影響都行數

*/

public int update(String sql,String... pras){

int resu=0;

con=getCon();

try {

ps=con.prepareStatement(sql);

for(int i=0;ipras.length;i++){

ps.setString(i+1,pras[i]);

}

resu=ps.executeUpdate();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

finally{

closeAll();

}

return resu;

}

/**

* @param sql數據庫查詢語句

* @param pras參數列表（可傳，可不傳，不傳為NULL，以數組形式存在）

* @return 返回結果集

*/

public ResultSet query(String sql,String... pras){

con=getCon();

try {

ps=con.prepareStatement(sql);

if(pras!=null)

for(int i=0;ipras.length;i++){

ps.setString(i+1, pras[i]);

}

rs=ps.executeQuery();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return rs;

} ?

}

java與sql連接

in thread "main" java.lang.Error: Unresolved compilation problem:一般是說沒有導包..

第一:你看看text1文件在那個包下面..比如我的是在test這個包下(package test);

package test;

public class Test {

}

dbConn = DriverManager.getConnection(dbURL,username,password);

Connection dbConn;

第二;你這里有問題..應該去掉dbConn = DriverManager.getConnection(dbURL,username,password);因為你沒有加載驅動是不能這樣調用的;

第三:你那些數據庫驅動jar包導入了沒有啊

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();

}

}