当前位置:首页 » 数据仓库 » 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("执行失败");
// }