Home >Database >Mysql Tutorial >java访问mysql数据库的方法_MySQL

java访问mysql数据库的方法_MySQL

WBOY
WBOYOriginal
2016-06-01 13:04:291181browse

1、下载接口程序包mysql-connector-java-5.0.8-bin.jar 下载地址

2、编程

(1)加载驱动

(2)编程连接操作

(3)返回结果处理

编程示例

import java.sql.*;

public class Access2Database{
	public Connection getConn(){
		Connection conn=null;
		try{
			Class.forName("com.mysql.jdbc.Driver");
			String url="jdbc:mysql://localhost:3306/mytest";
			String user="root";
			String password="111";
			conn=DriverManager.getConnection(url, user, password);
			if(conn!=null){
				System.out.println("The connection to database is successful!");
			}
		}catch(Exception e){
			e.printStackTrace();
		}
		return conn;
	}
	
	public ResultSet getResultSet(Statement stam,String sql){
		ResultSet res=null;
		try {
			res=stam.executeQuery(sql);
		} catch (SQLException e){
			e.printStackTrace();
		}
		return res;
	}
	void showResultSet(ResultSet res){}
}
import java.sql.*;

public class GetConnection{
	public static void main(String[] args){
		Access2Database adb=new Access2Database();
		Connection conn=adb.getConn();
		Statement stam=null;
		try {
			stam = conn.createStatement();
		} catch (SQLException e1) {
			e1.printStackTrace();
		}
		
		//show resultset
		String sql="select * from student;";
		ResultSet res=adb.getResultSet(stam, sql);
		try {
			System.out.println("name\tmajor\tscore");
			while(res.next()){
				String name,major;
				int score;
				name=res.getString(1);
				major=res.getString(2);
				score=res.getInt(3);
				System.out.println(name+"\t"+major+"\t"+score);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		try{
		res.close();
		}catch(SQLException e){
			e.printStackTrace();
		}
		
		//insert something into table
		sql="insert into student(name,major,score) values('f','Chinese','70');";
		try {
			stam.execute(sql);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		//delete something from the table
		sql="delete from student where name='f';";
		try{
			stam.executeUpdate(sql);
		}catch(SQLException e){
			e.printStackTrace();
		}
		
		//change the data int the table
		sql="update student set score=100 where name='a' and major='Chinese'";
		try{
			stam.executeUpdate(sql);
		}catch(SQLException e){
			e.printStackTrace();
		}
		
		//prepared statement
		sql="select * from student where name=?";
		PreparedStatement pstam=null;
		try {
			pstam=conn.prepareStatement(sql);
			pstam.setString(1, "a");
			res=pstam.executeQuery();
			System.out.println("**********************");
			while(res.next()){
				String name,major;
				int score;
				name=res.getString(1);
				major=res.getString(2);
				score=res.getInt(3);
				System.out.println(name+"\t"+major+"\t"+score);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		//release the resource of the program
		try{
			res.close();
			pstam.close();
			stam.close();
			conn.close();
		}catch(SQLException e){
			e.printStackTrace();
		}
	}
}
按需调整代码即可

 

Statement:
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn