public int insert(T t) throws Exception{ Connection connection=null; PreparedStatement ps=null; StringBuffer sql=new StringBuffer("insert into " ); //得到T的反射类 Class<?> aClass=t.getClass(); //获取类上注解 TableName tableName = aClass.getAnnotation(TableName.class); if (tableName==null){ throw new RuntimeException("未使用注解标记表名"); } //获取表名 String name = tableName.name(); sql.append(name+ " values"); try { List<Object> values = new ArrayList<Object>(); Field[] declaredFields = aClass.getDeclaredFields(); for (Field field : declaredFields) { field.setAccessible(true); Object v1 = field.get(t); values.add("'" + v1 + "'"); } String replace = values.toString().replace("[", "(").replace("]", ")"); sql.append(replace); connection = ConnectionFactory.getConnection(); ps = connection.prepareStatement(sql.toString()); int i = ps.executeUpdate(); return i; }catch (Exception e){ e.printStackTrace(); }finally { ConnectionFactory.close(null,ps,connection); } return 0; }
时间: 2024-02-15 20:28:05 浏览: 92
mysql+java课程设计学生管理系统
这段代码是用来实现数据库插入操作的,其中的T是一个泛型参数,可以代表任意一个Java类,而该类必须使用了@TableName注解标记了数据库表名。这个方法首先通过反射获取到T的Class对象,然后从该Class对象中获取@TableName注解并获取表名,接着通过反射获取到该类中所有的Field对象,遍历每个Field对象并获取其值,最后构造出一个SQL语句并执行数据库插入操作。需要注意的是,这段代码并没有对SQL注入进行防范,如果插入的数据中包含特殊字符,可能会导致SQL注入攻击。
阅读全文