前言
为了方便引入 mysql 的jar支持包，在此我选择工程支持maven
环境准备
JDK
mysql服务器（我采用xampp集成工具中的mysql）
myeclipse
顺便推荐一篇文章：MySQL 5.7 版本的安装及简单使用（图文教程）
先上工程结构图
工程目录结构
创建新web project项目CzgWeb
为了方便引入mysql的jar支持包，在此我选择工程支持maven。
创建工程
在工程的 pom .xml配置文件中添加mysql依赖
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector- java </artifactId>
<version>5.1.32</version>
<scope>provided</scope>
</dependency>
保存后，在Maven Dependencies中会有my sql 对应的依赖包（不像android stuido中还得点击同步）
在src目录创建mysql连接帮助类DBHelper.java
为了方便java文件测试（不通过项目测试），我们直接在本DBHelper添加main方法，直接运行
package util;
import java.sql.Connection;
import java.sql.DriverManager;
public class DBHelper {
private static final String driver = “com.mysql. jdbc .Driver”; //数据库驱动
//连接数据库的URL地址
private static final String url=”jdbc:mysql://localhost:3306/phpmyadmin?useUnicode=true&characterEncoding=UTF-8″;
private static final String username=”root”;//数据库的用户名
private static final String password=””;//数据库的密码
private static Connection conn=null;
//静态代码块负责加载驱动
static
{
try
{
Class.forName(driver);
}
catch(Exception ex)
{
ex.printStackTrace();
}
}
//单例模式返回数据库连接对象
public static Connection getConnection() throws Exception
{
if(conn==null)
{
conn = DriverManager.getConnection(url, username, password);
return conn;
}
return conn;
}
public static void main(String[] args) {
try
{
Connection conn = DBHelper.getConnection();
if(conn!=null)
{
System.out.println(“数据库连接正常！”);
}
else
{
System.out.println(“数据库连接异常！”);
}
}
catch(Exception ex)
{
ex.printStackTrace();
}
}
}
运行测试（选择Java Application）
运行DBHelper.java
连接测试结果
测试结果
在mysql的phpmyadmin数据库添加表items，并初始化数据
工具有管理
或 SQLyog
商品项目Items类
public class Items {
private int id; // 商品编号
private String name; // 商品名称
private String city; // 产地
private int price; // 价格
private int number; // 库存
private String picture; // 商品图片
//保留此不带参数的构造方法
public Items()
{
}
。。。
}
创建业务逻辑类ItemsDAO,并运行ItemsDAO.java
同样也添加上了main的方法方便测试
package dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import util.DBHelper;
import entity.Items;
//商品的业务逻辑类
public class ItemsDAO {
// 根据商品编号获得商品资料
public Items getItemsById(int id) {
Connection conn = null;
PreparedStatement stmt = null;
ResultSet rs = null;
try {
conn = DBHelper.getConnection();
String sql = “select * from items where id=?;”; // SQL语句
stmt = conn.prepareStatement(sql);
stmt.setInt(1, id);
rs = stmt.executeQuery();
if (rs.next()) {
Items item = new Items();
item.setId(rs.getInt(“id”));
item.setName(rs.getString(“name”));
item.setCity(rs.getString(“city”));
item.setNumber(rs.getInt(“number”));
item.setPrice(rs.getInt(“price”));
item.setPicture(rs.getString(“picture”));
return item;
} else {
return null;
}
} catch (Exception ex) {
ex.printStackTrace();
return null;
} finally {
// 释放数据集对象
if (rs != null) {
try {
rs.close();
rs = null;
} catch (Exception ex) {
ex.printStackTrace();
}
}
// 释放语句对象
if (stmt != null) {
try {
stmt.close();
stmt = null;
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
}
//为了方便独立测试添加main方法
public static void main(String[] args) {
ItemsDAO idao = new ItemsDAO();
Items item = idao.getItemsById(Integer.parseInt(“2”));
if (item !=null){
System.out.println(item.getCity());
System.out.println(item);
}else{
System.out.println(“没有找到商品”);
}
}
查询测试结果
