前言

为了方便引入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中会有mysql对应的依赖包（不像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，并初始化数据

工具有http://localhost/phpmyadmin/管理

或 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("没有找到商品");

}

}

查询测试结果

分享是一种美德，牵手是一种生活方式。

最后感谢今日头条提供的分享平台，你觉得有用可以收藏方便以后查阅