java如何连接mysql底层封装
这篇文章主要介绍java如何连接MySQL底层封装,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!
创新互联建站是一家专注于成都网站制作、成都做网站、外贸营销网站建设与策划设计,高昌网站建设哪家好?创新互联建站做网站,专注于网站建设十多年,网设计领域的专业建站公司;建站业务涵盖:高昌等地区。高昌做网站价格咨询:18982081108
具体内容如下
连接数据库
package com.dao.db;import java.sql.Connection;import java.sql.SQLException;/** * 数据库连接层MYSQL * @author Administrator * */public class DBConnection { /** * 连接数据库 * @return */ public static Connection getDBConnection() { // 1. 注册驱动 try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } // 获取数据库的连接 try { Connection conn = java.sql.DriverManager.getConnection("jdbc:mysql://localhost/mysql?useUnicode=true&characterEncoding=utf-8", "root", "root"); return conn; } catch (SQLException e1) { e1.printStackTrace(); } return null; } }
数据层封装
package com.dao.db;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.ResultSetMetaData;import java.sql.SQLException;import java.sql.Types;import java.util.ArrayList;import java.util.HashMap;/** * MYSQL数据库底层封装 * @author Administrator * */public class DBManager { private PreparedStatement pstmt; private Connection conn; private ResultSet rs; /** * 打开数据库 */ public DBManager() { conn = DBConnection.getDBConnection(); } /** * 执行修改添加操作 * @param coulmn * @param type * @param sql * @return * @throws SQLException */ public boolean updateOrAdd(String[] coulmn, int[] type, String sql) throws SQLException { if(!setPstmtParam(coulmn, type, sql)) return false; boolean flag = pstmt.executeUpdate()>0?true:false; closeDB(); return flag; } /** * 获取查询结果集 * @param coulmn * @param type * @param sql * @throws SQLException */ public DataTable getResultData(String[] coulmn, int[] type, String sql) throws SQLException { DataTable dt = new DataTable(); ArrayList 数据集封装 package com.dao.db;import java.util.ArrayList;import java.util.HashMap;import java.util.Iterator;import java.util.Map;import java.util.Set;/** * 数据集封装 * @author Administrator * */public class DataTable { public String[] column;//列字段 public String[][] row; //行值 public int rowCount = 0;//行数 public int colCoun = 0;//列数 public DataTable() { super(); } public DataTable(String[] column, String[][] row, int rowCount, int colCoun) { super(); this.column = column; this.row = row; this.rowCount = rowCount; this.colCoun = colCoun; } public void setDataTable(ArrayList 测试Demo package com.bussiness.test;import java.sql.SQLException;import java.sql.Types;import com.dao.db.DBManager;import com.dao.db.DataTable;public class TestBusIness{ static String searchSql = "select * from score"; static String insertSql = "insert into score(name, age, score)values(?,?,?)"; static String deleteSql = "delete from score where id = ?"; static String updateSql = "update score set name = ? where id = ?"; public static void main(String[] args) { intsertData(); searchData(); } private static void intsertData() { DBManager dm = new DBManager(); String[] coulmn = new String[]{"wyf2", "23", "89.5"}; int[] type = new int[]{Types.CHAR, Types.INTEGER, Types.DOUBLE}; try { boolean flag = dm.updateOrAdd(coulmn, type, insertSql); if(flag) System.out.println("插入成功"); } catch (SQLException e) { e.printStackTrace(); } } private static void searchData() { DBManager dm = new DBManager(); String[] coulmn = null; int[] type = null; try { DataTable dt = dm.getResultData(coulmn, type, searchSql); if(dt != null && dt.getRowCount()> 0){ for(int i = 0; i 以上是“java如何连接mysql底层封装”这篇文章的所有内容,感谢各位的阅读!希望分享的内容对大家有帮助,更多相关知识,欢迎关注创新互联行业资讯频道!
网页标题:java如何连接mysql底层封装
链接分享:http://scyanting.com/article/gsiijh.html