PHP脚本和JAVA连接mysql数据库

st0627

　　PHP学习笔记——PHP脚本和JAVA连接mysql数据库
　　环境
　　开发包：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
　　
　　test.php测试
　　
　　运行截图：
　　java连接方式
　　1.新建一个java project为mysqlTest
　　2.加载JDBC驱动,mysql-connector-java-5.1.37
　　MySQLConnection.java
　　package com.mysqltest;
　　import java.sql.Connection;
　　import java.sql.DriverManager;
　　import java.sql.SQLException;
　　/*
　　* **Mysql连接**
　　*
　　* 参数：
　　* conn 连接
　　* url mysql数据库连接地址
　　* user 数据库登陆账号
　　* password 数据库登陆密码
　　* 方法：
　　* conn 获取连接
　　*/
　　publicclass MySQLConnection {
　　publicstatic Connection conn = null;
　　publicstatic String driver ="com.mysql.jdbc.Driver";
　　publicstatic String url ="jdbc:mysql://127.0.0.1:3306/post";
　　publicstatic String user ="root";
　　publicstatic String password ="123";
　　/*

　　* 创建Mysql数据连接第一步：加载驱动>　　*DriverManager.getConnection(url, user, password);
　　*/
　　public Connection conn() {
　　try {
　　Class.forName(driver);
　　} catch (ClassNotFoundException e) {
　　System.out.println("驱动加载错误");
　　e.printStackTrace();
　　}
　　try {
　　conn = DriverManager.getConnection(url, user, password);
　　} catch (SQLException e) {
　　System.out.println("数据库链接错误");
　　e.printStackTrace();
　　}
　　return conn;
　　}
　　}
　　Work.java
　　package com.mysqltest;
　　import java.sql.Connection;
　　import java.sql.PreparedStatement;
　　import java.sql.ResultSet;
　　import java.sql.SQLException;
　　/*
　　* mysql增删改查
　　*/
　　publicclass Work {
　　/*
　　* insert增加
　　*/
　　publicstaticint insert() {
　　MySQLConnection connection = new MySQLConnection();
　　Connection conns; // 获取连接
　　PreparedStatement pst; // 执行Sql语句
　　int i = 0;
　　String sql = "insert into user (username,password)values(?,?)";
　　try {
　　conns = connection.conn();
　　pst = conns.prepareStatement(sql);
　　pst.setString(1, "lizi");
　　pst.setString(2, "123");
　　i= pst.executeUpdate();
　　pst.close();
　　conns.close();
　　} catch (SQLException e) {
　　System.out.println("数据写入失败");
　　e.printStackTrace();
　　}
　　return i;
　　}
　　/*
　　* select写入
　　*/
　　publicstaticvoid select() {
　　MySQLConnection connection = new MySQLConnection();
　　Connection conns; // 获取连接
　　PreparedStatement pst; // 执行Sql语句(Statement)
　　ResultSet rs; // 获取返回结果
　　String sql = "select * from user";
　　try {
　　conns = connection.conn();
　　pst = conns.prepareStatement(sql);
　　rs = pst.executeQuery(sql);// 执行sql语句
　　System.out.println("---------------------------------------");
　　System.out.println("名字        |       密码");
　　while (rs.next()) {
　　System.out.println(rs.getString("username") + "        |       " + rs.getString("password"));
　　}
　　System.out.println("---------------------------------------");
　　conns.close();
　　pst.close();
　　rs.close();
　　} catch (SQLException e) {
　　System.out.println("数据查询失败");
　　e.printStackTrace();
　　}
　　}
　　/*
　　* update修改
　　*/
　　publicstaticint update() {
　　MySQLConnection connection = new MySQLConnection();
　　Connection conns; // 获取连接
　　PreparedStatement pst; // 执行Sql语句(Statement)
　　int i = 0;
　　String sql = "update user set password = ? where username =?";
　　try {
　　conns = connection.conn();
　　pst = conns.prepareStatement(sql);
　　pst.setString(1, "123");
　　pst.setString(2, "lizi");
　　i= pst.executeUpdate();
　　pst.close();
　　conns.close();
　　} catch (SQLException e) {
　　System.out.println("数据修改失败");
　　e.printStackTrace();
　　}
　　return i;
　　}
　　/*
　　* delete删除
　　*/
　　publicstaticint delete() {
　　MySQLConnection connection = new MySQLConnection();
　　Connection conns; // 获取连接
　　PreparedStatement pst; // 执行Sql语句(Statement)
　　int i = 0;
　　String sql = "delete from user where username = ?";
　　try {
　　conns = connection.conn();
　　pst = conns.prepareStatement(sql);
　　pst.setString(1, "lizi");
　　i= pst.executeUpdate();
　　pst.close();
　　conns.close();
　　} catch (SQLException e) {
　　System.out.println("数据删除失败");
　　e.printStackTrace();
　　}
　　return i;
　　}
　　/*
　　* test
　　*/
　　publicstaticvoid main(String[] args) {
　　//System.out.println(insert());
　　select();
　　//System.out.println(update());
　　// System.out.println(delete());
　　}
　　}