Tag: insert update

使用JdbcBatchItemWriter更新重复键

spring批量为我的项目，我只是尝试从csv文件读取并将数据加载到数据库，使用JdbcBatchItemWriter作为编写器。 我正在寻找一种方法来告诉编写器插入一个新行，但是，在重复键（或重​​复的唯一标识符）更新行而不是失败。 我知道我可以直接在sql语句中执行此操作，但这将特定于Mysql，但我希望我的代码与DBMS无关。 这是我在java配置中的编写器声明 @Bean @StepScope public ItemWriter writerHeadingCollectionsToDb(DataSource datasource) { String sqlStatement = “INSERT INTO abcd(id, first_name, last_name, phone_number” + “VALUES (:id, :firstName, :lastName, :phoneNumber)”; JdbcBatchItemWriter itemWriter = new JdbcBatchItemWriter(); itemWriter.setSql(sqlStatement ); itemWriter.setDataSource(dataSource); itemWriter.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider()); return itemWriter; } 在此先感谢您的帮助

如何使用Java和MySQL确定插入或更新是否成功？

我正在使用Java连接到MySQL数据库。 我正在尝试将数据插入或更新到数据库中。 尽管我非常确定插入是成功的，但它返回false。 根据“execute”API，返回值为“如果第一个结果是ResultSet对象，则为true;如果是更新计数，则为false”或“没有结果”。 如何确定插入或更新是否成功？ public boolean insertSelections(String selection, String name){ String sql =”INSERT INTO WORKREPORT VALUES (?,?,?,?,?)”; boolean action = false; try { PreparedStatement stmt = conn.prepareStatement(sql); SimpleDateFormat dateFormat = new java.text.SimpleDateFormat(“yyyy：MM：dd hh:mm:ss”); String formatDate = dateFormat.format(new java.util.Date(System.currentTimeMillis())); java.util.Date mDate = dateFormat.parse(formatDate); java.sql.Timestamp timeStamp = new java.sql.Timestamp(System.currentTimeMillis()); // Date time= new Date(mDate.getTime()); stmt.setInt(1, Integer.parseInt(getNumberByName(name).trim())); […]

通过Java代码插入一些数据时，Sparql查询不会更新

我正在尝试通过我的java代码将数据插入到加载到Fuseki服务器的owl文件中。 更新查询不会给出任何错误消息。 但是owl文件没有更新。我正在使用jena库并使用java代码实现。 我的代码有什么问题？ public boolean addLecturerTriples(String fName, String lName, String id, String module) { try{ ArrayList subject = new ArrayList(); ArrayList predicate = new ArrayList(); ArrayList object = new ArrayList(); subject.add(“”); predicate.add(“”); object.add(“”); for(int i = 0; i < subject.size(); i++){ String qry = "INSERT DATA"+ "{"+ subject.get(i)+"\n"+ predicate.get(i)+"\n"+ object.get(i)+"\n"+ "}"; UpdateRequest update = […]