平武建站

java使用JDBC动态创建数据表及SQL预处理的方法

本文实例讲述了java使用JDBC动态创建数据表及SQL预处理的方法。分享给大家供大家参考，具体如下：

我们提供的服务有：成都网站设计、成都网站制作、微信公众号开发、网站优化、网站认证、土默特右旗ssl等。为近1000家企事业单位解决了网站和推广的问题。提供周到的售前咨询和贴心的售后服务，是有科学管理、有技术的土默特右旗网站制作公司

这两天由于公司的需求，客户需要自定义数据表的字段，导致每张表的字段都不是固定的而且很难有一个通用的模板去维护，所以就使用JDBC动态去创建数据表，然后通过表的字段动态添加数据，数据的来源主要是用户提供的Excel直接导入到数据库中。

如果考虑到字段的类型，可以通过反射的机制去获取，现在主要用户需求就是将数据导入到数据库提供查询功能，不能修改，所以就直接都使用String类型来处理数据更加便捷。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import java.util.PropertyResourceBundle;
import java.util.ResourceBundle;
public class DataBaseSql {
 //配置文件 读取jdbc的配置文件
 private static ResourceBundle bundle = PropertyResourceBundle.getBundle("db");
 private static Connection conn;
 private static PreparedStatement ps;
  /**
   * 创建表
   * @param tabName 表名称
   * @param tab_fields 表字段
   */
  public static void createTable(String tabName,String[] tab_fields) {
    conn = getConnection();  // 首先要获取连接，即连接到数据库
    try {
      String sql = "create table "+tabName+"(id int auto_increment primary key not null";
      if(tab_fields!=null&&tab_fields.length>0){
        sql+=",";
        int length = tab_fields.length;
        for(int i =0 ;i queryForPage(String tabName,int pageNo,int pageSize ,String[] tab_fields){
    conn = getConnection();  // 首先要获取连接，即连接到数据库
    List list = new ArrayList();
    try {
      String sql = "select * from "+tabName+" LIMIT ?,? ; ";
       System.out.println("查询sql:"+sql);
       //预处理SQL 防止注入
       ps = conn.prepareStatement(sql);
       //注入参数
       ps.setInt(1,pageNo);
       ps.setInt(2,pageSize);
      //查询结果集
      ResultSet rs = ps.executeQuery();
      //存放结果集
      while(rs.next()){
         String[] result = new String[tab_fields.length];
          for (int i = 0; i < tab_fields.length; i++) {
            result[i] = rs.getString(tab_fields[i]);
          }
         list.add(result);
        }
      //关闭流
      rs.close();
      ps.close();
      conn.close();  //关闭数据库连接
    } catch (SQLException e) {
       System.out.println("查询失败" + e.getMessage());
    }
    return list;
  }
  /**
   * 清空表数据
   * @param tabName 表名称
   */
  public static void delete(String tabName){
      conn = getConnection();  // 首先要获取连接，即连接到数据库
      try {
        String sql = "delete from "+tabName+";";
        System.out.println("删除数据的sql:"+sql);
        //预处理SQL 防止注入
        ps = conn.prepareStatement(sql);
        //执行
        ps.executeUpdate();
        //关闭流
        ps.close();
        conn.close();  //关闭数据库连接
      } catch (SQLException e) {
        System.out.println("删除数据失败" + e.getMessage());
      }
  }
  /**
   * 用于注入参数
   * @param ps
   * @param data
   * @throws SQLException
   */
   private static void excutePs(String sql,int length,String[] data) throws SQLException{
     //预处理SQL 防止注入
     ps = conn.prepareStatement(sql);
     //注入参数
     for(int i=0;i

数据库的配置文件 db.properties

db.username=root
db.password=root
db.classname=com.mysql.jdbc.Driver
db.url = jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull

更多关于java相关内容感兴趣的读者可查看本站专题：《Java+MySQL数据库程序设计总结》、《Java数据结构与算法教程》、《Java文件与目录操作技巧汇总》、《Java操作DOM节点技巧总结》和《Java缓存操作技巧汇总》

希望本文所述对大家java程序设计有所帮助。


标题名称：java使用JDBC动态创建数据表及SQL预处理的方法
浏览路径：http://pwwzsj.com/article/ihgege.html

其他资讯