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(); } } }
按需调整代码即可
时间: 2024-09-30 10:16:02