标准-JDBC-项目示例一

1.软件包规范的结构:

2.开始步骤顺序:

3.代码示范:

package com.yunhe.bean;public class BanJi {private int id;private String name;public int getId() {return id;}public void setId(int id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}public BanJi() {super();// TODO Auto-generated constructor stub}public BanJi(int id, String name) {super();this.id = id;this.name = name;}@Overridepublic String toString() {return "BanJi [id=" + id + ", name=" + name + "]";}}

package com.yunhe.util;import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;public class JDBCUtil {private static String url;private static String user;private static String password;static {try {Class.forName("com.mysql.jdbc.Driver");} catch (ClassNotFoundException e) {// TODO Auto-generated catch blocke.printStackTrace();}}public static Connection getConnection() throws SQLException {Properties properties = new Properties();try {properties.load(new FileInputStream(new File("cfg/jdbc.properties")));url = properties.getProperty("url");user = properties.getProperty("user");password = properties.getProperty("password");} catch (IOException e) {e.printStackTrace();}return DriverManager.getConnection(url, user, password);}public static void free(ResultSet rs, Statement stmt, Connection conn) {try {if (rs != null)rs.close();} catch (SQLException e) {e.printStackTrace();} finally {rs = null;try {if (stmt != null)stmt.close();} catch (SQLException e) {e.printStackTrace();} finally {stmt = null;try {if (conn != null)conn.close();} catch (SQLException e) {e.printStackTrace();} finally {conn = null;}}}}}

package com.yunhe.dao;import java.sql.SQLException;
import java.util.List;import com.yunhe.bean.BanJi;public interface BanJiDao {public abstract int addBanJi(String sql) throws SQLException;public int editBanJiById(String sql) throws SQLException;public int delBanJiById(String sql) throws SQLException;public BanJi findBanJiById(String sql) throws SQLException;public List findAllBanJi(String sql) throws SQLException;}

package com.yunhe.dao.impl;import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;import com.yunhe.bean.BanJi;
import com.yunhe.dao.BanJiDao;
import com.yunhe.util.JDBCUtil;public class BanJiDaoImpl implements BanJiDao {@Overridepublic int addBanJi(String sql) throws SQLException {Connection conn = JDBCUtil.getConnection();Statement stmt = conn.createStatement();int res = stmt.executeUpdate(sql);if (1 == res)System.out.println("add success");return res;}@Overridepublic int editBanJiById(String sql) throws SQLException {Connection conn = JDBCUtil.getConnection();Statement stmt = conn.createStatement();int res = stmt.executeUpdate(sql);if (1 == res)System.out.println("editBanJi success");return res;}@Overridepublic int delBanJiById(String sql) throws SQLException {Connection conn = JDBCUtil.getConnection();Statement stmt = conn.createStatement();int res = stmt.executeUpdate(sql);if (1 == res)System.out.println("delBanJi success");return res;}@Overridepublic BanJi findBanJiById(String sql) throws SQLException {Connection conn = JDBCUtil.getConnection();Statement stmt = conn.createStatement();ResultSet res = stmt.executeQuery(sql);BanJi banJi = null;while (res.next()) {banJi = new BanJi();banJi.setId(res.getInt("id"));banJi.setName(res.getString("name"));}return banJi;}@Overridepublic List findAllBanJi(String sql) throws SQLException {Connection conn = JDBCUtil.getConnection();Statement stmt = conn.createStatement();ResultSet res = stmt.executeQuery(sql);List banjilist = new ArrayList();while (res.next()) {BanJi banJi;banJi = new BanJi();banJi.setId(res.getInt("id"));banJi.setName(res.getString("name"));banjilist.add(banJi);}return banjilist;}}

package com.yunhe.dao;import java.sql.SQLException;
import java.util.List;import org.junit.Test;import com.yunhe.bean.BanJi;
import com.yunhe.dao.impl.BanJiDaoImpl;public class BanJiDaoTest {@Testpublic void testAddBanJi() {BanJiDaoImpl dao = new BanJiDaoImpl();try {String sql = "insert into tb_banJi(id,name) values(105,'android')";dao.addBanJi(sql);} catch (SQLException e) {e.printStackTrace();}}@Testpublic void testEditBanJiById() {BanJiDaoImpl dao = new BanJiDaoImpl();try {String sql = "update tb_banJi set name='java' where id=1001";dao.editBanJiById(sql);} catch (SQLException e) {e.printStackTrace();}}@Testpublic void testDelBanJiById() {BanJiDaoImpl dao = new BanJiDaoImpl();try {String sql = "delete from tb_banJi where id=105";dao.delBanJiById(sql);} catch (SQLException e) {e.printStackTrace();}}@Testpublic void testFindBanJiById() {BanJiDaoImpl dao = new BanJiDaoImpl();try {String sql = "select id,name from tb_banJi where id=105";BanJi res = dao.findBanJiById(sql);System.out.println(res);} catch (SQLException e) {e.printStackTrace();}}@Testpublic void testFindAllBanJi() {BanJiDaoImpl dao = new BanJiDaoImpl();try {String sql = "select id,name from tb_banJi";List res = dao.findAllBanJi(sql);for (BanJi temp : res)System.out.println(temp);} catch (SQLException e) {e.printStackTrace();}}}

存储账号 密码

url=jdbc:mysql://localhost:3306/test
user=root
password=root

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！