java 连接MYSQL 进行查询怎么修改-PHP中文网问答

微信公众号讲师中心

首页

文章

后端开发 web前端数据库开发工具 php框架常见问题科技 Java 系统教程电脑教程硬件教程手机教程软件教程游戏教程自媒体新闻

专题

后端开发 web前端数据库开发工具 php框架科技 Java 系统教程电脑教程硬件教程手机教程软件教程游戏教程新闻

AI工具

AI 聊天问答 Agent智能体 AI 文本写作 AI 绘画作图 AI 设计工具 AI 视频创作 AI 音频制作 AI 办公学习 AI 编程开发 Prompt指令

学习

大前端后端开发数据库移动端运维开发计算机基础

编程手册

大前端后端开发数据库移动端运维开发计算机基础

下载

js特效网站源码工具下载类库下载网站素材学习资源插件扩展手机/移动开发手机游戏

最近更新

搜索

后端开发 web前端数据库开发工具 php框架常见问题科技 Java 系统教程电脑教程硬件教程手机教程软件教程游戏教程

java 连接MYSQL 进行查询怎么修改

ringa_lee 2017-04-17 10:57:59

[Java讨论组]

500

import java.sql.Connection ;

import java.sql.DriverManager ;

import java.sql.Statement ;

public class shiyan4{

	public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;

	public static final String DBURL = "jdbc:mysql://localhost:3306/ace" ;

	public static final String DBUSER = "root" ;

	public static final String DBPASS = "root" ;

	public static void main(String args[]) throws Exception {  
		
		Connection conn = null ; 
		
		Statement stmt = null ;  
		
		Class.forName(DBDRIVER) ;  
		
		String sql = "SELECT user_name FROM users;";
		
		conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
		
		stmt = conn.createStatement() ;   
		
		stmt.executeUpdate(sql) ; 
		
		stmt.close() ;  
		
		conn.close() ;   
	}
}

请问这样怎么修改才能正常的进行查询和在java上输出查询到的信息

ringa_lee

全部回复(3)

PHPz2017-04-17 10:59:59 3楼

刚开始学习java时写的代码，oracle的，改成mysql的驱动和对应的用户名密码基本就可以了

package cn.database;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import oracle.jdbc.pool.OracleDataSource;

public class DataBase {

	private Connection conn = null;
	private Statement stmt = null;
	private ResultSet rs = null;

	public DataBase() {
		
		// oracle 的jdbc 连接
		try {
			OracleDataSource ds = new OracleDataSource();
			ds.setUser("uamqas02");
			ds.setPassword("uamqas02");
			ds.setURL("jdbc:oracle:thin:@localhost:1521:devdb01");
			conn = ds.getConnection();
			stmt = conn.createStatement();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}


	public ResultSet executeQuery(String sql) {
		rs = null;
		try {
			// stmt=conn.createStatement();
			rs = stmt.executeQuery(sql);
		} catch (SQLException e) {
			e.printStackTrace();
			System.err.println("executeQuerty:" + e.getMessage());
		}
		return rs;
	}

	// ---------------------------数据库的更新、修改、删除操作-------------------------------------------------
	public boolean executeUpdate(String sql) // 更新方法（增、删、改）
	{
		boolean temp = false;
		try {
			stmt = conn.createStatement();
			int i = stmt.executeUpdate(sql);
			if (i >= 1)
				temp = true;
		} catch (SQLException e) {
			e.printStackTrace();
			System.err.println("executeUpdate:" + e.getMessage());
		}
		return temp;
	}

	public boolean saveOrUpdateCommit(String sql, String sql2) {
		boolean temp = true;
		try {
			conn.setAutoCommit(false);
			stmt = conn.createStatement();
			stmt.addBatch(sql);
			stmt.addBatch(sql2);
			stmt.executeBatch();
			conn.commit();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			temp = false;
			// 回滚
			try {
				conn.rollback();
			} catch (SQLException e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
		}
		try {
			conn.commit();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			temp = false;
			e.printStackTrace();
		}
		return temp;
	}

	public void closeStmt() {
		try {
			stmt.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}

	public void closeConn() {
		try {
			conn.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
}