Rumah >pembangunan bahagian belakang >tutorial php >PHP学习笔记——PHP脚本和JAVA连接mysql数据库,学习笔记mysql_PHP教程
环境
开发包:appserv-win32-2.5.10
服务器:Apache2.2
数据库:phpMyAdmin
语言:php5,java
平台:windows 10
java驱动:mysql-connector-java-5.1.37
需求
编写一个PHP脚本语言,连接到phpMyAdmin数据库的test库
编写一个java web服务端,连接到phpMyAdmin数据库的test库
代码
php连接方式
mysql.php
<?<span>php </span><span>/*</span><span>**************************** *数据库连接 ****************************</span><span>*/</span> <span>$conn</span> = @<span>mysql_connect</span>("localhost","root","123"<span>); </span><span>if</span> (!<span>$conn</span><span>){ </span><span>die</span>("连接数据库失败:" . <span>mysql_error</span><span>()); } </span><span>mysql_select_db</span>("test", <span>$conn</span><span>); </span><span>//</span><span>字符转换,读库</span> <span>mysql_query</span>("set character set utf8"<span>); </span><span>mysql_query</span>("set names utf8"<span>); </span>?>
test.php测试
<?<span>php </span><span>error_reporting</span>(0); <span>//</span><span>防止报错</span> <span>include</span>('mysql.php'<span>); </span><span>$result</span>=<span>mysql_query</span>("select * from user"); <span>//</span><span>根据前面的计算出开始的记录和记录数 // 循环取出记录</span> <span>$six</span><span>; </span><span>while</span>(<span>$row</span>=<span>mysql_fetch_row</span>(<span>$result</span><span>)) { </span><span>echo</span> <span>$row</span>[0<span>]; </span><span>echo</span> <span>$row</span>[1<span>]; } </span>?>
运行截图 :java 连接方式
1.新建一个java project为mysqlTest
2.加载JDBC驱动,mysql-connector-java-5.1.37
MySQLConnection.java
<span>package</span><span> com.mysqltest; </span><span>import</span><span> java.sql.Connection; </span><span>import</span><span> java.sql.DriverManager; </span><span>import</span><span> java.sql.SQLException; </span><span>/*</span><span> * **Mysql连接** * * 参数: * conn 连接 * url mysql数据库连接地址 * user 数据库登陆账号 * password 数据库登陆密码 * 方法: * conn 获取连接 </span><span>*/</span> <span>public</span> <span>class</span><span> MySQLConnection { </span><span>public</span> <span>static</span> Connection conn = <span>null</span><span>; </span><span>public</span> <span>static</span> String driver = "com.mysql.jdbc.Driver"<span>; </span><span>public</span> <span>static</span> String url = "jdbc:mysql://127.0.0.1:3306/post"<span>; </span><span>public</span> <span>static</span> String user = "root"<span>; </span><span>public</span> <span>static</span> String password = "123"<span>; </span><span>/*</span><span> * 创建Mysql数据连接 第一步:加载驱动 Class.forName(Driver) 第二步:创建连接 * DriverManager.getConnection(url, user, password); </span><span>*/</span> <span>public</span><span> Connection conn() { </span><span>try</span><span> { Class.forName(driver); } </span><span>catch</span><span> (ClassNotFoundException e) { System.out.println(</span>"驱动加载错误"<span>); e.printStackTrace(); } </span><span>try</span><span> { conn </span>=<span> DriverManager.getConnection(url, user, password); } </span><span>catch</span><span> (SQLException e) { System.out.println(</span>"数据库链接错误"<span>); e.printStackTrace(); } </span><span>return</span><span> conn; } }</span>
Work.java
<span>package</span><span> com.mysqltest; </span><span>import</span><span> java.sql.Connection; </span><span>import</span><span> java.sql.PreparedStatement; </span><span>import</span><span> java.sql.ResultSet; </span><span>import</span><span> java.sql.SQLException; </span><span>/*</span><span> * mysql增删改查 </span><span>*/</span> <span>public</span> <span>class</span><span> Work { </span><span>/*</span><span> * insert 增加 </span><span>*/</span> <span>public</span> <span>static</span> <span>int</span><span> insert() { MySQLConnection connection </span>= <span>new</span><span> MySQLConnection(); Connection conns; </span><span>//</span><span> 获取连接</span> PreparedStatement pst; <span>//</span><span> 执行Sql语句</span> <span>int</span> i = 0<span>; String sql </span>= "insert into user (username,password) values(?,?)"<span>; </span><span>try</span><span> { conns </span>=<span> connection.conn(); pst </span>=<span> conns.prepareStatement(sql); pst.setString(</span>1, "lizi"<span>); pst.setString(</span>2, "123"<span>); i </span>=<span> pst.executeUpdate(); pst.close(); conns.close(); } </span><span>catch</span><span> (SQLException e) { System.out.println(</span>"数据写入失败"<span>); e.printStackTrace(); } </span><span>return</span><span> i; } </span><span>/*</span><span> * select 写入 </span><span>*/</span> <span>public</span> <span>static</span> <span>void</span><span> select() { MySQLConnection connection </span>= <span>new</span><span> MySQLConnection(); Connection conns; </span><span>//</span><span> 获取连接</span> PreparedStatement pst; <span>//</span><span> 执行Sql语句(Statement)</span> ResultSet rs; <span>//</span><span> 获取返回结果</span> String sql = "select * from user"<span>; </span><span>try</span><span> { conns </span>=<span> connection.conn(); pst </span>=<span> conns.prepareStatement(sql); rs </span>= pst.executeQuery(sql);<span>//</span><span> 执行sql语句</span> System.out.println("---------------------------------------"<span>); System.out.println(</span>"名字 | 密码"<span>); </span><span>while</span><span> (rs.next()) { System.out.println(rs.getString(</span>"username") + " | " + rs.getString("password"<span>)); } System.out.println(</span>"---------------------------------------"<span>); conns.close(); pst.close(); rs.close(); } </span><span>catch</span><span> (SQLException e) { System.out.println(</span>"数据查询失败"<span>); e.printStackTrace(); } } </span><span>/*</span><span> * update 修改 </span><span>*/</span> <span>public</span> <span>static</span> <span>int</span><span> update() { MySQLConnection connection </span>= <span>new</span><span> MySQLConnection(); Connection conns; </span><span>//</span><span> 获取连接</span> PreparedStatement pst; <span>//</span><span> 执行Sql语句(Statement)</span> <span>int</span> i = 0<span>; String sql </span>= "update user set password = ? where username = ?"<span>; </span><span>try</span><span> { conns </span>=<span> connection.conn(); pst </span>=<span> conns.prepareStatement(sql); pst.setString(</span>1, "123"<span>); pst.setString(</span>2, "lizi"<span>); i </span>=<span> pst.executeUpdate(); pst.close(); conns.close(); } </span><span>catch</span><span> (SQLException e) { System.out.println(</span>"数据修改失败"<span>); e.printStackTrace(); } </span><span>return</span><span> i; } </span><span>/*</span><span> * delete 删除 </span><span>*/</span> <span>public</span> <span>static</span> <span>int</span><span> delete() { MySQLConnection connection </span>= <span>new</span><span> MySQLConnection(); Connection conns; </span><span>//</span><span> 获取连接</span> PreparedStatement pst; <span>//</span><span> 执行Sql语句(Statement)</span> <span>int</span> i = 0<span>; String sql </span>= "delete from user where username = ?"<span>; </span><span>try</span><span> { conns </span>=<span> connection.conn(); pst </span>=<span> conns.prepareStatement(sql); pst.setString(</span>1, "lizi"<span>); i </span>=<span> pst.executeUpdate(); pst.close(); conns.close(); } </span><span>catch</span><span> (SQLException e) { System.out.println(</span>"数据删除失败"<span>); e.printStackTrace(); } </span><span>return</span><span> i; } </span><span>/*</span><span> * test </span><span>*/</span> <span>public</span> <span>static</span> <span>void</span><span> main(String[] args) { </span><span>//</span><span> System.out.println(insert());</span> <span> select(); </span><span>//</span><span> System.out.println(update()); </span><span>//</span><span> System.out.println(delete());</span> <span> } }<br /><br /></span>
test截图