當前位置:首頁 » 數據倉庫 » java讀取mysql資料庫
擴展閱讀
webinf下怎麼引入js 2023-08-31 21:54:13
堡壘機怎麼打開web 2023-08-31 21:54:11

java讀取mysql資料庫

發布時間: 2023-06-14 09:51:13

⑴ 如何在Java程序中訪問mysql資料庫中的數據並進行簡單的操作

import java.sql.*;

public class DBManager{

static Connection conn=null;
static{
System.out.println("in DBManager");
String dbName="ccrs";
try{
Class.forName("com.mysql.jdbc.Driver");
//配置數據源
String url="jdbc:mysql://192.168.1.2/"+ dbName +
"?useUnicode=true&characterEncoding=GB2312";
conn=DriverManager.getConnection(url,"root","admin");
}catch(Exception e){
System.out.println("Exception:"+e.getMessage());
}
}

public synchronized static Connection getConnection(){
Connection temp=null;
if(conn!=null){
temp=conn;
conn=null;
return temp;
}else{
return null;
}

}

public synchronized static void releaseConnection(Connection con){
conn=con;
}

public static void closeConn(){
try{
conn.close();
}catch(SQLException e){
System.out.println(e.getMessage());
}
}

}

你要注意的地方:dbName為資料庫名,你的mysql裡面的資料庫叫什麼,這個就為什麼,例如String dbName="yourDataBaseName";
Class.forName("com.mysql.jdbc.Driver"),這個就是你下的那個jar包,驅動
url="jdbc:mysql://localhost/"+ dbName +
"?useUnicode=true&characterEncoding=GB2312"; //localhost資料庫的機器名

conn=DriverManager.getConnection(url,"root","admin");
root是你資料庫的用戶名,admin為密碼,你看你自己的資料庫的用戶名密碼為多少,這里就為多少.

應該夠詳細了,還要注意的是你的驅動,即那個jar包你要放好,如果用eclipse的話導入你的工程屬性里.不然的話加入classpath.你不是jsp,所以不用放進你的lib里.

⑵ java中怎麼獲取mysql資料庫的數據

用JDBC連接資料庫,然後用sql語句。要導入mysql的驅動包。
import java.sql.*;

public class TestMySql {
static Connection con = null; // 聲明Connection對象
static Statement sql = null;
static ResultSet res = null;

public static void main(String[] args) {
TestMySql c = new TestMySql();
con = c.getConnection();
try {
sql = con.createStatement();
res = sql.executeQuery("select * from dept");
//sql語句,我資料庫里有張dept表

while (res.next()) {//輸出結果
System.out.print(res.getString(1) + "<——>");
System.out.print(res.getString(2) + "<——>");
System.out.print(res.getString(3) );
System.out.println();
}

} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
if (res != null) {
res.close();
res =null;
}
if (sql != null) {
sql.close();
sql =null;
}
if (con != null) {
con.close();
con =null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}

}

public Connection getConnection() {
try {
Class.forName("com.mysql.jdbc.Driver");
// 載入oracleJDBC驅動
System.out.println("資料庫驅動載入成功");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
try {// 通過訪問資料庫的URL獲取資料庫連接對象
con = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/mydata", "root", "qwer1234");
//mydata為mysql名字

System.out.println("資料庫連接成功");
} catch (SQLException e) {
e.printStackTrace();
}
return con; // 按方法要求返回一個Connection對象
}

}

⑶ java讀取MySQL資料庫

在String
value
=
rs.getString("name");
之前要先rs.next();一下
你用這個來判斷密碼錯誤?
if(!rs.isBeforeFirst()){
JOptionPane.showMessageDialog(frame,
"Wrong
password!");
}
isBeforeFirst()
的意思是:獲取游標是否位於此
ResultSet
對象的第一行之前。

⑷ 如何在Java程序中訪問mysql資料庫中的數據並進行簡單的操作

必須用JDBC技術。Mysql中實現了JDBC中的方法。具體的實現代碼如下:
package com.itheima.jdbc;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;
/**
* 創建資料庫連接
*
* @author 長孫建坤 18092853734
* @version 2017-04-26 20:41:35
*/
public class JDBCTest02 {

public void demo(){
System.out.println("ddd");
}
public static void main(String[] args) {
InputStream config = JDBCTest02.class.getClassLoader().getResourceAsStream("jdbc.properties");
Properties pro = new Properties();
try {
pro.load(config);
String driver = pro.getProperty("driver");
Class.forName(driver);
String username = pro.getProperty("user");
String password = pro.getProperty("password");
String url = pro.getProperty("url");
Connection con = DriverManager.getConnection(url, username, password);
String sql = "select * from perinfo";
PreparedStatement pst = con.prepareStatement(sql);

ResultSet set = pst.executeQuery();
while(set.next()){

System.out.println(set.getString(2));
}

String del = "DELETE FROM perinfo WHERE pid = ?";

pst.setObject(1, 5);

int update = pst.executeUpdate(del);
System.out.println(update);
} catch (IOException e) {
new RuntimeException(e + "配置文件讀取失敗!");
} catch (SQLException e) {
new RuntimeException(e + "連接獲取失敗!");
} catch (ClassNotFoundException e) {
new RuntimeException(e + "類文件載入失敗!");
}
}
}

⑸ JAVA怎麼讀取mysql資料庫啊,救命

importjava.sql.*;
publicclasslogin{
publicstaticvoidmain(String[]args){
try{

Class.forName("com.mysql.jdbc.Driver");
Connectionct=DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/qj","root","admin");
Statementsm=ct.createStatement();
//sm.executeQuery("useqj");
ResultSetrs=sm.executeQuery("='admin'");
Stringpasswd=rs.getString(1);
System.out.println(passwd);
}
catch(Exceptione){
e.printStackTrace();}
}

}

⑹ 如何在Java程序中訪問mysql資料庫中的數據並進行簡單的操作

/**
*獲取資料庫的連接
*@returnconn
*/
()throwsException{
Stringurl="jdbc:mysql://10.10.35.188:3306/sgjwx";
Stringuser="opermain";
Stringpsw="opermain";
Connectionconn=null;
PreparedStatementpstm=null;
ResultSetrs=null;
Class.forName("com.mysql.jdbc.Driver");
if(null==conn){
try{
conn=DriverManager.getConnection(url,user,psw);
}catch(SQLExceptione){
System.out.println("獲取失敗");
thrownewRuntimeException(e);
}finally{
closeResources(conn,pstm,rs);
}
}
returnconn;
}
/**
*釋放資源
*@paramconn
*@parampstmt
*@paramrs
*/
(Connectionconn,PreparedStatementpstmt,ResultSetrs){
if(null!=rs){
try{
rs.close();
}catch(SQLExceptione){
e.printStackTrace();
thrownewRuntimeException(e);
}finally{
if(null!=pstmt){
try{
pstmt.close();
}catch(SQLExceptione){
e.printStackTrace();
thrownewRuntimeException(e);
}finally{
if(null!=conn){
try{
conn.close();
}catch(SQLExceptione){
e.printStackTrace();
thrownewRuntimeException(e);
}
}
}
}
}
}
}


// //tuserrole執行插入
// try{
// Stringsql="insertintosys_userrole(roleid,userid)values(?,?)";
// conn=getConnection();
// conn.setAutoCommit(false);
// PreparedStatementpstmt=(PreparedStatement)conn.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);//傳入參數:Statement.RETURN_GENERATED_KEYS
// pstmt.setInt(1,5);
// pstmt.setInt(2,sid);
// pstmt.executeUpdate();
// ResultSetrs=pstmt.getGeneratedKeys();//獲取結果
// inta=-1;
// if(rs.next()){
// a=rs.getInt(1);//取得ID
// }
// System.out.println(a);
// System.out.println("t_userrole執行成功");
// conn.commit();
// }catch(Exceptione){
// e.printStackTrace();
// System.out.println("執行失敗");
// }