Выполните несколько команд в одном ExecuteScalar в Oracle
Я подумал о термине «Потребитель» - компьютер или сервер, потребляющий Тему от Брокера. Вот почему я запутался с Consumer group.
Потребитель - это клиент или программа, и у меня может быть много потребителей на моем компьютере или сервере. Под Consumer Group подразумевается несколько процессов-потребителей на независимой машине
. Поэтому мне не нужно беспокоиться о том, что Consumer в группе совместно использует биты сообщения для завершения темы. Раньше я думал, что каждый потребитель - это сервер или вычислительный ресурс, поэтому ему приходилось как-то общаться. Но вот как я запутался. Им не нужно общаться друг с другом по сети или им нужен пул для совместного использования их разделенных разделов.
Потребитель 1 может читать из раздела 1, Потребитель 2 может читать из раздела 2, и если Потребитель 1, 2 имеет один и тот же идентификатор группы (Группа потребителей), Потребителю 1 не нужно читать из раздела 2, и Потребителю 2 не нужно читать из раздела 1. У них уже есть тема, в которой они нуждаются. Бум!
Я опубликовал ответ, чтобы помочь кому-то, кто думал, как я.
2 ответа
Попытайтесь перенестись с a BEGIN..END
BEGIN insert into.... ; insert into.... ; delete .........; END;
попытка НАЧАТЬ КОНЕЦ не работала на меня.
То, что я сделал, было, делают новый метод, который, учитывая соединение (я пытаюсь минимизировать свои открытые соединения) это разделяет операторы с помощью; как разделитель и выполнения каждый seperatly
private void ExecuteSql(string statements, IDbConnection conn)
{
IDbCommand cmd = conn.CreateCommand();
string[] commands = statements.Split(new string[] { ";\r\n", "; ", ";\t", ";\n" }, StringSplitOptions.RemoveEmptyEntries);
foreach (string c in commands)
{
cmd.CommandText = c;
cmd.CommandType = CommandType.Text;
cmd.ExecuteNonQuery();
}
cmd.Dispose();
}
Мое вдохновение прибыло из этого сообщения после того, как Petros сказал мне об этом
PS Вы, возможно, должны изменить его согласно своим потребностям в моем случае, я требую, чтобы соединение было открыто, и закрытое соответственно, если что-то происходит от вызывающей стороны.