JDBC連接MYSQL資料庫:
package cn.outofmemory.test;
import java.sql.Connection;
import java.sql.DriverManager;
public class Mysql {
public static void main(String arg[]) {
try {
Connection con = null; //定義一個MYSQL鏈接對象
Class.forName("com.mysql.jdbc.Driver").newInstance(); //MYSQL驅動
con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "root"); //鏈接本地MYSQL
System.out.print("yes");
} catch (Exception e) {
System.out.print("MYSQL ERROR:" + e.getMessage());
}
}
}
Class.forName("com.mysql.jdbc.Driver").newInstance(); 我們鏈接的是MYSQL資料庫,所以需要一個MYSQL的資料庫驅動,如果你的環境中沒有安裝,
可以下載:mysql-connector-java-5.1.17-bin.jar JAR包,然後放進jdk1.6.0_37\jre\lib\ext 重啟eclispe 就可以在JRE系統庫中看到。
con = DriverManager.getConnection;("jdbc:mysql://127.0.0.1:3306/test", "root", "root"); 是鏈接資料庫的語句,
返回Connection con;對象。參數格式:("jdbc:mysql://ip:埠/資料庫名稱", 用戶名,密碼)
寫入一條數據
package main;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class Mysql {
/**
* 入口函數
* @param arg
*/
public static void main(String arg[]) {
try {
Connection con = null; //定義一個MYSQL鏈接對象
Class.forName("com.mysql.jdbc.Driver").newInstance(); //MYSQL驅動
con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "root"); //鏈接本地MYSQL
Statement stmt; //創建聲明
stmt = con.createStatement();
//新增一條數據
stmt.executeUpdate("INSERT INTO user (username, password) VALUES ('init', '123456')");
ResultSet res = stmt.executeQuery("select LAST_INSERT_ID()");
int ret_id;
if (res.next()) {
ret_id = res.getInt(1);
System.out.print(ret_id);
}
} catch (Exception e) {
System.out.print("MYSQL ERROR:" + e.getMessage());
}
}
}
stmt.executeUpdate INSERT; DELETE; UPDATE;語句都用executeUpdate函數來操作
stmt.executeQuery SELECT;語句都用stmt.executeQuery函數來操作
ResultSet res = stmt.executeQuery;("select LAST;_INSERT_ID()");
查詢最後插入數據的ID號,返回ResultSet res;對象
刪除和更新數據
package main;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class Mysql {
/**
* 入口函數
* @param arg
*/
public static void main(String arg[]) {
try {
Connection con = null; //定義一個MYSQL鏈接對象
Class.forName("com.mysql.jdbc.Driver").newInstance(); //MYSQL驅動
con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "root"); //鏈接本地MYSQL
Statement stmt; //創建聲明
stmt = con.createStatement();
//新增一條數據
stmt.executeUpdate("INSERT INTO user (username, password) VALUES ('init', '123456')");
ResultSet res = stmt.executeQuery("select LAST_INSERT_ID()");
int ret_id;
if (res.next()) {
ret_id = res.getInt(1);
System.out.print(ret_id);
}
//刪除一條數據
String sql = "DELETE FROM user WHERE id = 1";
long deleteRes = stmt.executeUpdate(sql); //如果為0則沒有進行刪除操作,如果大於0,則記錄刪除的條數
System.out.print("DELETE:" + deleteRes);
//更新一條數據
String updateSql = "UPDATE user SET username = 'xxxx' WHERE id = 2";
long updateRes = stmt.executeUpdate(updateSql);
System.out.print("UPDATE:" + updateRes);
} catch (Exception e) {
System.out.print("MYSQL ERROR:" + e.getMessage());
}
}
}
刪除和更新數據都使用stmt.executeUpdate函數。
刪除和更新數據都會返回一個Long的結果,如果為0,則刪除或者更新失敗,如果大於0則是操作刪除的記錄數
查詢語句
package main;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.Statement;
public class Mysql {
/**
* 入口函數
* @param arg
*/
public static void main(String arg[]) {
try {
Connection con = null; //定義一個MYSQL鏈接對象
Class.forName("com.mysql.jdbc.Driver").newInstance(); //MYSQL驅動
con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "root"); //鏈接本地MYSQL
Statement stmt; //創建聲明
stmt = con.createStatement();
//新增一條數據
stmt.executeUpdate("INSERT INTO user (username, password) VALUES ('init', '123456')");
ResultSet res = stmt.executeQuery("select LAST_INSERT_ID()");
int ret_id;
if (res.next()) {
ret_id = res.getInt(1);
System.out.print(ret_id);
}
//刪除一條數據
String sql = "DELETE FROM user WHERE id = 1";
long deleteRes = stmt.executeUpdate(sql); //如果為0則沒有進行刪除操作,如果大於0,則記錄刪除的條數
System.out.print("DELETE:" + deleteRes);
//更新一條數據
String updateSql = "UPDATE user SET username = 'xxxx' WHERE id = 2";
long updateRes = stmt.executeUpdate(updateSql);
System.out.print("UPDATE:" + updateRes);
//查詢數據並輸出
String selectSql = "SELECT * FROM user";
ResultSet selectRes = stmt.executeQuery(selectSql);
while (selectRes.next()) { //循環輸出結果集
String username = selectRes.getString("username");
String password = selectRes.getString("password");
System.out.print("\r\n\r\n");
System.out.print("username:" + username + "password:" + password);
}
} catch (Exception e) {
System.out.print("MYSQL ERROR:" + e.getMessage());
}
}
}
查詢語句使用stmt.executeQuery函數
rs.absolute() //絕對位置,負數表示從後面數
rs.first()第一條
rs.last()最後一條
rs.previoust()前一條
rs.next()後一條
rs.beforeFirst()第一條之前
rs.afterLast()最後之後
rs.isFirst(),rs.isLast(),rs.isBeforeFirst(),rs.isAfterLast
❷ 如何實現JDBC連接mysql資料庫
1.導入mysql資料庫的驅動jar包
如我的導的是mysql-connector-java-5.1.40.jar
2.注冊驅動
注冊驅動代碼為:Class.forName("com.mysql.jdbc.Driver")
3.獲取連接
Connection con = DriverManager.getConnection(url,username,password)
其中url為 jdbc:mysql://localhost:3306/xun?useSSL=false,後面那個xun為資料庫的庫名,如果不使用加密的話,?useSSL=false這個其實也可以省略,省略後為jdbc:mysql://localhost:3306/xun,不過最好還是別省略哈。
4.獲取PrepareStatement並發送sql查詢語句
String sql = "select * from user where username = ?"(這個查詢語句為隨便舉的例子哈)
PreparedStatement pst = con.preparedStatement(sql);
pst.setString(1,"zengjiaxun");
ResultSet rs = pst.executeQuery();
注意,執行查詢使用的是executeQuery()方法,此方法返回的是ResultSet,ResultSet為結果集,封裝了查詢結果。插入,刪除,修改用的是executeUpdate()方法。
pst.clearParameters();
執行sql後記得關閉相應的流。。
❸ 怎麼通過jdbc連接mysql資料庫
•創建一個以JDBC連接資料庫的程序,包含7個步驟:
1、載入JDBC驅動程序:
在連接資料庫之前,首先要載入想要連接的資料庫的驅動到JVM(Java虛擬機),
這通過java.lang.Class類的靜態方法forName(String className)實現。
例如:
try{
//載入MySql的驅動類
Class.forName("com.mysql.jdbc.Driver") ;
}catch(ClassNotFoundException e){
System.out.println("找不到驅動程序類 ,載入驅動失敗!");
e.printStackTrace() ;
}
成功載入後,會將Driver類的實例注冊到DriverManager類中。
2、提供JDBC連接的URL
•連接URL定義了連接資料庫時的協議、子協議、數據源標識。
•書寫形式:協議:子協議:數據源標識
協議:在JDBC中總是以jdbc開始
子協議:是橋連接的驅動程序或是資料庫管理系統名稱。
數據源標識:標記找到資料庫來源的地址與連接埠。
例如:(MySql的連接URL)
jdbc:mysql:
//localhost:3306/test?useUnicode=true&characterEncoding=gbk ;
useUnicode=true:表示使用Unicode字元集。如果characterEncoding設置為
gb2312或GBK,本參數必須設置為true 。characterEncoding=gbk:字元編碼方式。
3、創建資料庫的連接
•要連接資料庫,需要向java.sql.DriverManager請求並獲得Connection對象,
該對象就代表一個資料庫的連接。
•使用DriverManager的getConnectin(String url , String username ,
String password )方法傳入指定的欲連接的資料庫的路徑、資料庫的用戶名
❹ JDBC是什麼
JDBC庫包含的API為每個通常與資料庫的使用相關聯的任務:
使得連接到資料庫
創建SQL或MySQL語句
執行SQL或MySQL的查詢資料庫
查看和修改結果記錄從根本上說,JDBC是一種規范,它提供的介面,一套完整的,允許攜帶型訪問底層資料庫。可以用Java來寫不同類型的可執行文件,如:
Java應用程序
JavaApplets
JavaServlets
JavaServerPages(JSP)
EnterpriseJavaBeans(EJBs)所有這些不同的可執行文件就可以使用JDBC驅動程序來訪問資料庫,並把存儲的數據的優勢。
JDBC提供了相同的功能,ODBC,允許Java程序包含與資料庫無關的代碼。
先決條件:
以前正如期進行本教程,需要具備以下兩個主題內容很好的了解:
核心Java編程
SQL或MySQL資料庫
JDBC架構:
JDBCAPI支持兩層和三層處理模型進行資料庫訪問,但在一般的JDBC體系結構由兩層組成:
JDBCAPI:提供了應用程序對JDBC的管理連接。
JDBCDriverAPI:支持JDBC管理到驅動器連接。JDBCAPI的使用驅動程序管理器和資料庫特定的驅動程序提供透明的連接到異構資料庫。
JDBC驅動程序管理器可確保正確的驅動程序來訪問每個數據源。該驅動程序管理器能夠支持連接到多個異構資料庫的多個並發的驅動程序。
以下是結構圖,它顯示了驅動程序管理器方面的JDBC驅動程序和Java應用程序的位置:
常見的JDBC組件:
JDBCAPI提供了以下介面和類:
DriverManager:這個類管理資料庫驅動程序的列表。內容是否符合從Java應用程序使用的通信子協議正確的資料庫驅動程序的連接請求。識別JDBC在一定子協議的第一個驅動器將被用來建立資料庫連接。
Driver:此介面處理與資料庫伺服器通信。很少直接與驅動程序對象。相反,使用DriverManager中的對象,它管理此類型的對象。它也抽象與驅動程序對象工作相關的詳細信息
Connection:此介面與接觸資料庫的所有方法。連接對象表示通信上下文,即,與資料庫中的所有的通信是通過唯一的連接對象。
Statement:可以使用這個介面創建的對象的SQL語句提交到資料庫。一些派生的介面接受除執行存儲過程的參數。
ResultSet:這些對象保存從資料庫後,執行使用Statement對象的SQL查詢中檢索數據。它作為一個迭代器,讓您可以通過移動它的數據。
SQLException:這個類處理發生在一個資料庫應用程序的任何錯誤。
❺ 在使用jdbc將mysql中的數據查詢出來更新到sqlserve資料庫時,怎麼自動轉換類型
在使用jdbc將mysql中的數據查詢出來更新到sqlserve資料庫時,怎麼自動轉換類型
JDBC操作MySQL資料庫的步驟
1、准備MySQL資料庫驅動包:mysql-connector-java-5.0.8-bin.jar,一個項目中只能存在一個版本的驅動包
a、復制該驅動包,粘貼到項目中
b、選中項目里的驅動包,右鍵->Build Path->Add to Build Path
2、在類里寫代碼載入驅:決定連接哪種資料庫
a、Class.forName("com.mysql.jdbc.Driver");
b、必須進行異常處理:ClassNotFoundException
3、連接資料庫
a、Connection con=DriverManager.getConnection("連接字元串", "用戶名", "密碼");
b、連接字元串格式固定,不同資料庫,格式不同:jdbc:mysql://要連接的計算機名稱:埠號/要連接的資料庫名稱
c、必須進行異常處理:SQLException
4、拼寫要執行的sql語句,必須是可以在資料庫中執行的
5、創建執行sql語句的對象
a、Statement stmt=con.createStatement();
b、注意:Statement必須來自於java.sql包中
6、執行sql語句
a、執行insert、update和delete語句:int row=stmt.executeUpdate(sql);返回影響行數
b、執行查詢語句:ResultSet rs=stmt.executeQuery(sql);返回查詢結果
c、執行任意sql語句(DDL、DCL、DML和DQL等)
7、對執行結果進行處理
a、執行更新語句:判斷影響行數是否為0,0表示失敗,非0表示成功
b、對查詢結果進行處理:
1) 結果集需要先移動、後取值 :rs.next();int id=rs.getInt(1);
String name=rs.getString("loginName");
2) 結果集有多條時,需要循環操作:
while(rs.next()){ System.out.println(rs.getInt(1)+"\t"+rs.getString(2)+"\t"+rs.getString(3)+"\t"+rs.getString(4)+"\t"+rs.getInt(5));
}
3) 不確定是否有查詢結果時:if(rs.next()){說明有查詢結果}else{沒有查詢結果}
4) 使用了聚合函數,一定有查詢結果,查詢結果是一行一列:
rs.next();
int result=rs.getInt(1);
注意:結果集取值時取出的時查詢語句中包含的欄位,與表中欄位無關
9、關閉相關對象(先關閉結果集對象、在關閉執行語句對象,最後關閉連接對象)
例如:執行查詢語句
Scanner input=new Scanner(System.in);
System.out.print("請輸入登錄名: ");
String name=input.next();
System.out.print("請輸入密碼: ");
String pass=input.next();
try {
Class.forName("com.mysql.jdbc.Driver");
Connection con=DriverManager.getConnection("jdbc:mysql://localhost:3306/userdb", "root", "root");
String sql="select COUNT(*) from UserInfo where loginName='"+name+"' and loginPass='"+pass+"'";
Statement stmt=con.createStatement();
ResultSet rs=stmt.executeQuery(sql);
rs.next();
int result=rs.getInt(1);
if(result!=0){
System.out.println("登錄成功!");
}else{
System.out.println("用戶名或密碼錯誤,請重新登錄!");
}
rs.close();
stmt.close();
con.close();
} catch (ClassNotFoundException e) {
System.out.println("載入驅動錯誤:"+e.getMessage());
} catch (SQLException e) {
System.out.println("資料庫操作錯誤:"+e.getMessage());
}
執行添加、修改和刪除語句
try {
//載入驅動
Class.forName("com.mysql.jdbc.Driver");
//連接資料庫
Connection con=DriverManager.getConnection("jdbc:mysql://localhost:3306/userdb", "root", "root");
//拼寫要執行的sql語句
String sql="update UserInfo set loginPass='111' where loginName='a'";
//String sql="insert UserInfo values(default,'test','test')";
//String sql="delete from UserInfo where loginName='a'";
//創建執行語句對象
Statement stmt=con.createStatement();
//執行
int row=stmt.executeUpdate(sql);
//處理結果
if(row==0){
System.out.println("修改失敗!");
}else{
System.out.println("修改成功!");
}
//關閉
stmt.close();
con.close();
} catch (ClassNotFoundException e) {
System.out.println("驅動載入錯誤:"+e.getMessage());
} catch (SQLException e) {
System.out.println("資料庫操作錯誤:"+e.getMessage());
}
❻ eclipse用jdbc連接mysql資料庫時,url是填什麼怎樣找出地址
1、首先登陸mysql,查看mysql的數據情況,select * from test_data1 t
❼ java中怎樣對mysql資料庫查詢
importjava.sql.Connection;
importjava.sql.DriverManager;
importjava.sql.ResultSet;
importjava.sql.ResultSetMetaData;
importjava.sql.Statement;
importjava.util.Hashtable;
publicclassGetDBFiled{
publicstaticvoidconn(){
Stringdriver="com.mysql.jdbc.Driver";
Stringurl="jdbc:mysql://localhost:3306/databaseName";
Stringuser="root";
Stringpassword="密碼";
try{
Class.forName(driver);
Connectionconn=DriverManager.getConnection(url,user,password);
if(!conn.isClosed()){
Stringsql="select*frompic";
System.out.println("!");
Statementstatement=conn.createStatement();
ResultSetrs=statement.executeQuery(sql);
if(rs.next()){
//得到ResultSetMetaData
ResultSetMetaDatarsmd=rs.getMetaData();
System.out.println(rsmd.getColumnCount());
for(inti=1;i<=rsmd.getColumnCount();i++){
Hashtablehst=newHashtable();
//把欄位名放入Name
Stringname=String.valueOf(rsmd.getColumnLabel(i));
hst.put("Name",name);
//把欄位類型放入Type
Stringtype=String.valueOf(rsmd.getColumnType(i));
hst.put("Type",type);
System.out.println(hst.get("Name")+""+hst.get("Type"));
}
}
}
}catch(Exceptione){
System.out.println("出現異常");
}
}
}
❽ 用JDBC查詢MYSQL元數據的問題,請高手解答!
在建立資料庫 連接的 時候
這么寫:
DriverManager.getConnection("jdbc:mysql://localhost:3306/student?user=root&password=root&useUnicode=true&characterEncoding=utf-8");
&useUnicode=true&characterEncoding=utf-8" 主要是這句話。