java访问mysql数据库的方法_MySQL
程序员文章站
2022-04-22 10:32:37
...
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(); } } }按需调整代码即可
推荐阅读
-
mysql统计总数条件判断的方法介绍
-
Ubuntu14.04服务器环境下配置PHP7.0+Apache2+Mysql5.7的方法
-
PHP 获取MySQL数据库里所有表的实现代码
-
Mysql误操作后利用binlog2sql快速回滚的方法详解
-
mysql报错:Deadlock found when trying to get lock; try restarting transaction的解决方法
-
阿里云Linux CentOS 7.2下自建MySQL的root密码忘记的解决方法
-
使用wordpress的$wpdb类读mysql数据库做ajax时出现的问题该如何解决
-
C#访问SQL Server数据库的实现方法
-
MySQL给新建用户并赋予权限最简单的方法
-
一台linux主机启动多个MySQL数据库的方法