Binod's Blog

CREATE SEQUENCE orders_order_id_seq;
CREATE TABLE orders
(
	order_id 	INTEGER NOT NULL PRIMARY KEY DEFAULT(NEXTVAL('orders_order_id_seq')::INTEGER),
	order_date	TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT(NOW()),
	customer_name	character varying(40) NOT NULL
);
 
CREATE SEQUENCE ordered_products_ordered_product_id_seq;
CREATE TABLE ordered_products
(
	ordered_product_id	INTEGER NOT NULL PRIMARY KEY DEFAULT(NEXTVAL('ordered_products_ordered_product_id_seq')::INTEGER),
	order_id		INTEGER NOT NULL REFERENCES orders(order_id),
	product_name		character varying(40) NOT NULL
);
 
CREATE UNIQUE INDEX ordered_products_product_name_uix
ON ordered_products(order_id, UPPER(product_name));

DO
$$
DECLARE _order_id INTEGER;
BEGIN
	INSERT INTO orders(customer_name)
	SELECT 'Rudolf Schenker';
 
	_order_id:=CURRVAL('orders_order_id_seq')::INTEGER;
 
	INSERT INTO ordered_products(order_id, product_name)
	SELECT _order_id, 'Holiday' UNION ALL
	SELECT _order_id, 'Wind of Change' UNION ALL
	SELECT _order_id, 'Under the Same Sun' UNION ALL
	SELECT _order_id, 'When You Came into My Life' UNION ALL
	SELECT _order_id, 'Rock You Like a Hurricane';
	RAISE NOTICE 'The transaction was successfully processed.';
EXCEPTION
	WHEN OTHERS THEN
	RAISE NOTICE 'The transaction was rolled back, nothing was changed.';
END
$$
LANGUAGE plpgsql;

public bool SaveOrder(string customerName, List products)
{
	using (NpgsqlConnection pgConnection = new NpgsqlConnection("Server=localhost;User id=postgres;password=binod;Database=postgres;"))
	{
		try
		{
			pgConnection.Open();
			//Connection successful
 
			//Create a new transaction
			using (NpgsqlTransaction pgTransaction = pgConnection.BeginTransaction())
			{
				try
				{
					using (NpgsqlCommand roleCommand = new NpgsqlCommand("INSERT INTO orders(customer_name) SELECT @customer_name;SELECT CURRVAL('orders_order_id_seq')::integer as order_id;", pgConnection, pgTransaction))
					{
						roleCommand.Parameters.AddWithValue("@customer_name", customerName);
 
						//Get the newly inserted row_id of the current scope
						int orderId = Convert.ToInt32(roleCommand.ExecuteScalar());
 
						foreach (string product in products)
						{
							using (NpgsqlCommand userCommand = new NpgsqlCommand("INSERT INTO ordered_products(order_id, product_name) SELECT @order_id, @product_name;", pgConnection, pgTransaction))
							{
								userCommand.Parameters.AddWithValue("@order_id", orderId);
								userCommand.Parameters.AddWithValue("@product_name", product);
								userCommand.ExecuteNonQuery();
							}
						}
 
						//No exceptions encountered
						pgTransaction.Commit();
 
						//System.Windows.Forms.MessageBox.Show("Task completed successfully.", "Success", MessageBoxButtons.OK, MessageBoxIcon.Information);
						return true;
					}
				}
				catch
				{
					//Transaction rolled back to the original state
					pgTransaction.Rollback();
					throw;
				}
			}
		}
		catch (NpgsqlException ex)
		{
			MessageBox.Show(ex.Message, "Error", MessageBoxButtons.OK, MessageBoxIcon.Error);
		}
		catch
		{
			throw;
		}
	}
	return false;
}

List<string> products = new List<string>();
products.Add("Holiday");
products.Add("Wind of Change");
products.Add("Under the Same Sun");
products.Add("When You Came into My Life");
products.Add("Rock You Like a Hurricane");
 
SaveOrder("Rudolf Schenker",products);

Function SaveOrder(ByVal customerName As String, ByVal products As List(Of String)) As Boolean
	Using pgConnection As NpgsqlConnection = New NpgsqlConnection("Server=localhost;User id=postgres;password=binod;Database=postgres;")
		Try
			pgConnection.Open()
			'Connection successful
 
			'Create a new transaction
			Using pgTransaction As NpgsqlTransaction = pgConnection.BeginTransaction()
				Try
					Using roleCommand As NpgsqlCommand = New NpgsqlCommand("INSERT INTO orders(customer_name) SELECT @customer_name;SELECT CURRVAL('orders_order_id_seq')::integer as order_id;", pgConnection, pgTransaction)
						roleCommand.Parameters.AddWithValue("@customer_name", customerName)
 
						'Get the newly inserted row_id of the current scope
						Dim orderId As Integer = Convert.ToInt32(roleCommand.ExecuteScalar())
 
						For Each product As String In products
							Using userCommand As NpgsqlCommand = New NpgsqlCommand("INSERT INTO ordered_products(order_id, product_name) SELECT @order_id, @product_name;", pgConnection, pgTransaction)
								userCommand.Parameters.AddWithValue("@order_id", orderId)
								userCommand.Parameters.AddWithValue("@product_name", product)
								userCommand.ExecuteNonQuery()
							End Using
						Next
 
						'No exceptions encountered
						pgTransaction.Commit()
 
						'System.Windows.Forms.MessageBox.Show("Task completed successfully.", "Success", MessageBoxButtons.OK, MessageBoxIcon.Information)
						Return True
					End Using
				Catch
					'Transaction rolled back to the original state
					pgTransaction.Rollback()
					Throw
				End Try
			End Using
		Catch ex As NpgsqlException
			MessageBox.Show(ex.Message, "Error", MessageBoxButtons.OK, MessageBoxIcon.Error)
		Catch
			Throw
		End Try
	End Using
	Return False
End Function

Dim products As List(Of String) = New List(Of String)
products.Add("Holiday")
products.Add("Wind of Change")
products.Add("Under the Same Sun")
products.Add("When You Came into My Life")
products.Add("Rock You Like a Hurricane")
 
SaveOrder("Rudolf Schenker", products)