- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
表结构如下
1. mail_contacts(id,mail_id);//stores mail id, id is primary key
mail_id is unique key
2. inv_table(mid,aid,add_date);//mapped mail id with user id. mid is
mail_contacts id and aid is userid
(mid,aid) is primary key
插入后,我将多个邮件 ID 存储在 mail_contacts
中,我正在获取其插入的 ID 并将其存储在 inv_table
的帮助下。如果任何 mail_id
没有存储在 mail_contacts
中,那么它工作正常。但如果 mail_id
存储在 mail_contacts
中,则插入将终止。
我想要什么 如果 mail_id
存储在 mail_contacts
中,那么它应该获取它的 id
以存储在inv_table
.
我在努力
PreparedStatement ps = null;
PreparedStatement ps1 = null;
ResultSet rs = null, res = null;
Connection con = null;
String status = "success";
ArrayList ar = null;
Invitation invi = null;
int i = 0;
public String insert(List<MailidInvitation> invitationList, Long aid) {
con = ConnectionFactory.getConnection();
try {
ps = con.prepareStatement("insert into mail_contacts(mail_id)"
+ " values(?)", Statement.RETURN_GENERATED_KEYS);
for (MailidInvitation a : invitationList) {
ps.setString(1, a.getMailId());
ps.addBatch();
}
ps.executeBatch();
ResultSet keys = ps.getGeneratedKeys();
while (keys.next()) {
long id = keys.getLong(1);
invitationList.get(i).setId(id);
System.out.println("generated id is " + id);
i++;
}
ps1 = con.prepareStatement("insert into inv_table(mid,aid)"
+ " values(?,?)");
for (MailidInvitation a : invitationList) {
ps1.setLong(1, a.getId());
ps1.setLong(2, aid);
ps1.addBatch();
}
ps1.executeBatch();
} catch (SQLException e) {
status = "failure";
System.out.println("SQLException1 " + e);
} finally {
try {
con.close();
} catch (SQLException e) {
System.out.println("SQLException2 " + e);
}
}
System.out.println("Status is " + status);
return status;
}
如何做到这一点?
解决这类问题最好的方法是什么
我使用的是mysql数据库
最佳答案
第一种方法在处理批量 INSERT 时不对 JDBC 驱动程序的行为做出任何假设。它通过
避免了潜在的 INSERT 错误mail_id
我们当前数据集中的值,id
那些的值(value)mail_id
确实存在的值(value)观,mail_id
不存在的值,并检索它们的(新)id
值(value)观,然后inv_table
) 中插入行。try (Connection dbConn = DriverManager.getConnection(myConnectionString, "root", "usbw")) {
dbConn.setAutoCommit(false);
// test data and setup
Long aid = 123L;
List<MailidInvitation> invitationList = new ArrayList<MailidInvitation>();
invitationList.add(new MailidInvitation(13L));
invitationList.add(new MailidInvitation(11L));
invitationList.add(new MailidInvitation(12L));
// remove stuff from previous test run
try (Statement s = dbConn.createStatement()) {
s.executeUpdate("DELETE FROM mail_contacts WHERE mail_id IN (11,13)");
}
try (PreparedStatement ps = dbConn.prepareStatement(
"DELETE FROM inv_table WHERE aid=?")) {
ps.setLong(1, aid);
ps.executeUpdate();
}
// real code starts here
//
// create a Map to hold `mail_id` and their corresponding `id` values
Map<Long, Long> mailIdMap = new TreeMap<Long, Long>();
for (MailidInvitation a : invitationList) {
// mail_id, id (id is null for now)
mailIdMap.put(a.getId(), null);
}
// build an SQL statement to retrieve any existing values
StringBuilder sb = new StringBuilder(
"SELECT id, mail_id " +
"FROM mail_contacts " +
"WHERE mail_id IN (");
int n = 0;
for (Map.Entry<Long, Long> entry : mailIdMap.entrySet()) {
if (n++ > 0) sb.append(',');
sb.append(entry.getKey());
}
sb.append(')');
String sql = sb.toString();
// run the query and save the results (if any) to the Map
try (Statement s = dbConn.createStatement()) {
// <demo>
System.out.println(sql);
// </demo>
try (ResultSet rs = s.executeQuery(sql)) {
while (rs.next()) {
mailIdMap.put(rs.getLong("mail_id"), rs.getLong("id"));
}
}
}
// <demo>
System.out.println();
System.out.println("mailIdMap now contains:");
// </demo>
// build a list of the `mail_id` values to INSERT (where id == null)
// ... and print the existing mailIdMap values for demo purposes
List<Long> mailIdsToInsert = new ArrayList<Long>();
for (Map.Entry<Long, Long> entry : mailIdMap.entrySet()) {
String idValue = ""; // <demo />
if (entry.getValue() == null) {
mailIdsToInsert.add(entry.getKey());
// <demo>
idValue = "null";
} else {
idValue = entry.getValue().toString();
// </demo>
}
// <demo>
System.out.println(String.format(
" %d - %s",
entry.getKey(),
idValue));
// </demo>
}
// batch insert `mail_id` values that don't already exist
try (PreparedStatement ps = dbConn.prepareStatement(
"INSERT INTO mail_contacts (mail_id) VALUES (?)",
PreparedStatement.RETURN_GENERATED_KEYS)) {
for (Long mid : mailIdsToInsert) {
ps.setLong(1, mid);
ps.addBatch();
}
ps.executeBatch();
// get generated keys and insert them into the Map
try (ResultSet rs = ps.getGeneratedKeys()) {
n = 0;
while (rs.next()) {
mailIdMap.put(mailIdsToInsert.get(n++), rs.getLong(1));
}
}
}
// <demo>
System.out.println();
System.out.println("After INSERT INTO mail_contacts, mailIdMap now contains:");
for (Map.Entry<Long, Long> entry : mailIdMap.entrySet()) {
System.out.println(String.format(
" %d - %s",
entry.getKey(),
entry.getValue()));
}
// </demo>
// now insert the `inv_table` rows
try (PreparedStatement ps = dbConn.prepareStatement(
"INSERT INTO inv_table (mid, aid) VALUES (?,?)")) {
ps.setLong(2, aid);
for (MailidInvitation a : invitationList) {
ps.setLong(1, mailIdMap.get(a.getId()));
ps.addBatch();
}
ps.executeBatch();
}
dbConn.commit();
}
最终的控制台输出如下所示:
SELECT id, mail_id FROM mail_contacts WHERE mail_id IN (11,12,13)
mailIdMap now contains:
11 - null
12 - 1
13 - null
After INSERT INTO mail_contacts, mailIdMap now contains:
11 - 15
12 - 1
13 - 16
如果批处理中的一个或多个语句失败,一些 JDBC 驱动程序允许批处理继续执行。例如,在 MySQL Connector/J 中,选项是 continueBatchOnError
这是true
默认情况下。在这些情况下,另一种方法是尝试插入所有 mail_id
值并检查批处理返回的更新计数。成功的 INSERT 将返回 UpdateCount 1,而失败的 INSERT 将返回现有的 mail_id
。会返回 EXECUTE_FAILED
(-3)。然后我们可以检索(新)id
通过 .getGeneratedKeys()
成功插入的值,然后继续构建一个 SELECT 语句以返回并检索 id
mail_id
的值已经存在的条目。
所以代码是这样的
// create a Map to hold `mail_id` and their corresponding `id` values
Map<Long, Long> mailIdMap = new TreeMap<Long, Long>();
for (MailidInvitation a : invitationList) {
// mail_id, id (id is null for now)
mailIdMap.put(a.getId(), null);
}
// try INSERTing all `mail_id` values
try (PreparedStatement ps = dbConn.prepareStatement(
"INSERT INTO mail_contacts (mail_id) VALUES (?)",
PreparedStatement.RETURN_GENERATED_KEYS)) {
for (Long mid : mailIdMap.keySet()) {
ps.setLong(1, mid);
ps.addBatch();
}
int[] updateCounts = null;
try {
updateCounts = ps.executeBatch();
} catch (BatchUpdateException bue) {
updateCounts = bue.getUpdateCounts();
}
// get generated keys and insert them into the Map
try (ResultSet rs = ps.getGeneratedKeys()) {
int i = 0;
for (Long mid : mailIdMap.keySet()) {
if (updateCounts[i++] == 1) {
rs.next();
mailIdMap.put(mid, rs.getLong(1));
}
}
}
}
// <demo>
System.out.println("mailIdMap now contains:");
// </demo>
// build a SELECT statement to get the `id` values for `mail_id`s that already existed
// ... and print the existing mailIdMap values for demo purposes
StringBuilder sb = new StringBuilder(
"SELECT id, mail_id " +
"FROM mail_contacts " +
"WHERE mail_id IN (");
int n = 0;
for (Map.Entry<Long, Long> entry : mailIdMap.entrySet()) {
String idValue = ""; // <demo />
if (entry.getValue() == null) {
if (n++ > 0) sb.append(',');
sb.append(entry.getKey());
// <demo>
idValue = "null";
} else {
idValue = entry.getValue().toString();
// </demo>
}
// <demo>
System.out.println(String.format(
" %d - %s",
entry.getKey(),
idValue));
// </demo>
}
sb.append(')');
String sql = sb.toString();
// <demo>
System.out.println();
System.out.println(sql);
// </demo>
会产生这样的控制台输出:
mailIdMap now contains:
11 - 17
12 - null
13 - 19
SELECT id, mail_id FROM mail_contacts WHERE mail_id IN (12)
其余过程与之前相同:
mailIdMap
条目,和id
在另一个表上处理 INSERT mailIdMap
中的值.关于java - 将行添加到具有唯一列 : Get existing ID values plus newly-created ones 的表,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/26858270/
我正在 csv 上使用 hadoop 来分析一些数据。我使用sql/mysql(不确定)来分析数据,现在陷入了僵局。 我花了好几个小时在谷歌上搜索,却没有找到任何相关的东西。我需要一个查询,在该查询中
我正在为 Bootstrap 网格布局的“简单”任务而苦苦挣扎。我希望在大视口(viewport)上有 4 列,然后在中型设备上有 2 列,最后在较小的设备上只有 1 列。 当我测试我的代码片段时,似
对于这个令人困惑的标题,我深表歉意,我想不出这个问题的正确措辞。相反,我只会给你背景信息和目标: 这是在一个表中,一个人可能有也可能没有多行数据,这些行可能包含相同的 activity_id 值,也可
具有 3 列的数据库表 - A int , B int , C int 我的问题是: 如何使用 Sequelize 结果找到 A > B + C const countTasks = await Ta
我在通过以下功能编写此查询时遇到问题: 首先按第 2 列 DESC 排序,然后从“不同的第 1 列”中选择 只有 Column1 是 DISTINCT 此查询没有帮助,因为它首先从第 1 列中进行选择
使用 Bootstrap 非常有趣和有帮助,目前我在创建以下需求时遇到问题。 “使用 bootstrap 在桌面上有 4 列,在平板电脑上有 2 列,在移动设备上有 1 列”谁能告诉我正确的结构 最佳
我是 R 新手,正在问一个非常基本的问题。当然,我在尝试从所提供的示例中获取指导的同时做了功课here和 here ,但无法在我的案例中实现这个想法,即可能是由于我的问题中的比较维度更大。 我的实
通常我会使用 R 并执行 merge.by,但这个文件似乎太大了,部门中的任何一台计算机都无法处理它! (任何从事遗传学工作的人的附加信息)本质上,插补似乎删除了 snp ID 的 rs 数字,我只剩
我有一个 df , delta1 delta2 0 -1 2 0 -1 0 0 0 我想知道如何分配 delt
您好,我想知道是否可以执行以下操作。显然,我已经尝试在 phpMyAdmin 中运行它,但出现错误。也许还有另一种方式来编写此查询。 SELECT * FROM eat_eat_restaurants
我有 2 个列表(标题和数据值)。我想要将数据值列 1 匹配并替换为头文件列 1,以获得与 dataValue 列 1 和标题值列 2 匹配的值 头文件 TotalLoad,M0001001 Hois
我有两个不同长度的文件,file2 是一个很大的引用文件,我从中提取文件 1 的数据。 我有一行 awk,我通常会对其进行调整以在我的文件中进行查找和替换,但它总是在同一列中进行查找和替换。 所以对于
假设我有两个表,如下所示。 create table contract( c_ID number(1) primary key, c_name varchar2(50) not
我有一个带有 varchar 列的 H2 表,其检查约束定义如下: CONSTRAINT my_constraint CHECK (varchar_field <> '') 以下插入语句失败,但当我删
这是最少量的代码,可以清楚地说明我的问题: One Two Three 前 2 个 div 应该是 2 个左列。第三个应该占据页面的其余部分。最后,我将添加选项来隐藏和
在 Azure 中的 Log Analytics 中,我为 VM Heartbeat 选择一个预定义查询,我在编辑器中运行查询正常,但当我去创建警报时,我不断收到警报“查询未返回 TimeGenera
在 Azure 中的 Log Analytics 中,我为 VM Heartbeat 选择一个预定义查询,我在编辑器中运行查询正常,但当我去创建警报时,我不断收到警报“查询未返回 TimeGenera
今天我开始使用 JexcelApi 并遇到了这个:当您尝试从特定位置获取元素时,不是像您通常期望的那样使用sheet.getCell(row,col),而是使用sheet.getCell(col,ro
我有一个包含 28 列的数据库。第一列是代码,第二列是名称,其余是值。 public void displayData() { con.Open(); MySqlDataAdapter
我很沮丧:每当我缩小这个网页时,一切都变得一团糟。我如何将网页居中,以便我可以缩小并且元素不会被错误定位。 (它应该是 2 列,但所有内容都合并为 1)我试过 但由于某种原因,这不起作用。 www.o
我是一名优秀的程序员,十分优秀!