Add this line to your application's Gemfile:
gem 'umbrellio-sequel-plugins'And then execute:
$ bundle
CurrencyRatesPGToolsSlaveSynchronizeMethods in MigrationsDeferrable Foreign KeysSet LocalMigration Transaction OptionsFibered Connection Pool
Plugin for joining currency rates table to any other table and money exchange.
Enable: DB.extension :currency_rates
Currency rates table example:
CREATE TABLE currency_rates (
id integer NOT NULL,
currency text NOT NULL,
period tsrange NOT NULL,
rates jsonb NOT NULL
);
INSERT INTO currency_rates (currency, period, rates) VALUES
('EUR', tsrange('2019-02-07 16:00:00 +0300', '2019-02-07 16:00:00 +0300'), '{"USD": 1.1, "EUR": 1.0, "RUB": 81}'),
('EUR', tsrange('2019-02-07 17:00:00 +0300', NULL), '{"USD": 1.2, "EUR": 1.0, "RUB": 75}')Usage example:
CREATE TABLE items (
id integer NOT NULL,
currency text NOT NULL,
price numeric NOT NULL,
created_at timestamp without time zone NOT NULL
);
INSERT INTO items (currency, price, created_at) VALUES ("EUR", 10, '2019-02-07 16:10:00 +0300')DB[:items]
.with_rates
.select(Sequel[:price].exchange_to("USD").as(:usd_price))
.first
# => { "usd_price" => 12.0 }Enable: DB.extension :pg_tools
Plugins for getting all inherited tables.
Example:
DB.inherited_tables_for(:event_log) # => [:event_log_2019_01, :event_log_2019_02]Enable: DB.extension :slave
Plugin for choosing slave server for query.
Example:
DB[:users].slave.where(email: "[email protected]") # executes on a slave serverImportant: you have to define a server named 'slave' in sequel config before using it.
Enable: DB.extension :synchronize
Plugin for using transaction advisory locks for application-level mutexes.
Example:
DB.synchronize_with([:ruby, :forever]) { p "Hey, I'm in transaction!"; sleep 5 }
# => BEGIN
# => SELECT pg_try_advisory_xact_lock(3764656399) -- 'ruby-forever'
# => COMMITEnable: Sequel.extension(:methods_in_migrations). Also, you will need to add and require symbiont-ruby gem.
Support for method definitions and invocations inside Sequel.migration.
Example:
Sequel.extension(:methods_in_migrations)
Sequel.migration do
# define
def get_data
# ...some code...
end
# use
up { get_data }
down { get_data }
# without extension:
# => NameError: undefined local variable or method `get_data' for #<Sequel::Postgres::Database>
endEnable: Sequel.extension(:deferrable_foreign_keys)
Makes foreign keys constraints deferrable (DEFERABLE INITIALLY DEFERRED) by default.
Example:
DB.create_table(:users) { primary_key :id }
DB.create_table(:items) do
primary_key :id
foreign_key :user_id, :users
endCREATE TABLE users (
id integer NOT NULL
);
CREATE TABLE items (
id integer NOT NULL
);
-- without extension:
ALTER TABLE items ADD CONSTRAINT items_user_id_fkey FOREIGN KEY (user_id) REFERENCES users(id);
-- with extension:
ALTER TABLE items ADD CONSTRAINT items_user_id_fkey FOREIGN KEY (user_id) REFERENCES users(id) DEFERRABLE INITIALLY DEFERRED;OR
# wives attributes: id (pk), husband_id (fk)
# husbands attributes: id (pk), wife_id (fk)
Wife = Sequel::Model(:wives)
Husband = Sequel::Model(:husbands)
DB.transaction do
wife = Wife.create(id: 1, husband_id: 123456789)
husband = Husband.create(id: 1)
wife.update(husband_id: husband.id)
husband.update(wife_id: wife.id)
end
# assume there are no husband with id=123456789
# without extension:
# => Sequel::ForeignKeyConstraintViolation: Key (husband_id)=(123456789) is not present in table "husbands".
# with extension:
# => <Wife @attributes={id:1, husband_id: 1}>
# => <Husband @attributes={id:1, wife_id: 1}>Enable: DB.extension(:set_local)
Makes possible to set transaction locals.
Example:
DB.transaction(set_local: { lock_timeout: "5s", statement_timeout: "5s" }) {}BEGIN;
SET LOCAL lock_timeout = '5s';
SET LOCAL statement_timeout = '5s';
COMMIT;Enable: Sequel.extension(:migration_transaction_options)
Makes possible to pass transaction_options in migrations.
Example:
Sequel.migration do
transaction_options rollback: :always
up { DB.select("1") }
endBEGIN;
SELECT '1';
ROLLBACK;Sequel connection pool for fiber powered web servers or applications (e.g. falcon, async)
Runtime dependency: async
You need to make sure that command require "async" works for your project.
The main difference from default Sequel::ThreadedConnectionPool that you can skip max_connections
configuration to produce as much connection as your application neeeded.
Also there is no any thead-safe code with synchronize and etc. So this connection pool works much faster.
Enable:
Put this code before your application connects to database
Sequel.extension(:fiber_concurrency) # Default Sequel extension for fiber isolation level
Sequel.extension(:fibered_connection_pool)Enable: Sequel::Model.plugin :attr_encrypted
Plugin for storing encrypted model attributes.
Example:
Sequel.migration do
change do
alter_table :orders do
add_column :encrypted_first_name, :text
add_column :encrypted_last_name, :text
add_column :encrypted_secret_data, :text
end
end
end
class Order < Sequel::Model
attr_encrypted :first_name, :last_name, key: Settings.private_key
attr_encrypted :secret_data, key: Settings.another_private_key
end
Order.create(first_name: "Ivan")
# => INSERT INTO "orders" ("encrypted_first_name") VALUES ('/sTi9Q==$OTpuMRq5k8R3JayQ$WjSManQGP9UaZ3C40yDjKg==')
order = Order.create(first_name: "Ivan", last_name: "Smith",
secret_data: { "some_key" => "Some Value" })
order.first_name # => "Ivan"
order.secret_data # => { "some_key" => "Some Value" }Enable: Sequel::Model.plugin :duplicate
Model plugin for creating a copies.
Example:
User = Sequel::Model(:users)
user1 = User.create(name: "John")
user2 = user1.duplicate(name: "James")
user2.name # => "James"OR
user2 = User.duplicate(user1, name: "James")
user2.name # => "James"Enable: Sequel::Model.plugin :get_column_value
Plugin for getting raw column value
Example:
item = Item.first
item.price # => #<Money fractional:5000.0 currency:USD>
item.get_column_value(:amount) # => 0.5e2Important: requires money gem described below.
Plugin for using money field keys as model properties.
Enable:
gem "money"
Sequel::Model.plugin :money_accessorsExamples of usage:
class Order < Sequel::Model
money_accessor :amount, :currency
end
order = Order.create(amount: 200, currency: "EUR")
order.amount # => #<Money fractional:20000.0 currency:EUR>
order.currency # => "EUR"
order.amount = Money.new(150, "RUB")
order.amount # => #<Money fractional:150.0 currency:RUB>class Order < Sequel::Model
money_setter :amount, :currency
end
order = Order.create(amount: 200, currency: "EUR")
order.amount = Money.new(150, "RUB")
order.currency # => "RUB"class Order < Sequel::Model
money_getter :amount, :currency
end
order = Order.create(amount: 200, currency: "EUR")
order.amount # => #<Money fractional:20000.0 currency:EUR>
order.currency # => "EUR"Enable: Sequel::Model.plugin :store_accessors
Plugin for using jsonb field keys as model properties.
Example:
class User < Sequel::Model
store :data, :first_name, :last_name
end
user = User.create(first_name: "John")
user.first_name # => "John"
user.data # => {"first_name": "John"}Important: requires a synchronize extension described below.
Same as DB#synchronize_with
Enable:
DB.extension :synchronize
Sequel::Model.plugin :synchronizeExample:
user = User.first
user.synchronize([:ruby, :forever]) { p "Hey, I'm in transaction!"; sleep 5 }Enable: Sequel::Model.plugin :upsert
Plugin for create an "UPSERT" requests to database.
Example:
User.upsert(name: "John", email: "[email protected]", target: :email)
User.upsert_dataset.insert(name: "John", email: "[email protected]")Enable: Sequel::Model.plugin :with_lock
Plugin for locking row for update.
Example:
user = User.first
user.with_lock do
user.update(name: "James")
endAllows to undo a specific migration
Example:
m = Sequel::TimestampMigrator.new(DB, "db/migrations")
m.undo(1549624163) # 1549624163 is a migration versionAlso you can use sequel:undo rake task for it.
Example:
rake sequel:undo VERSION=1549624163Overrides Rails default dbconsole and db commands. In order to use it, you have to add the following line to your boot.rb file:
require "umbrellio_sequel_plugins/rails_db_command"We have added a set of Rake tasks to manage ClickHouse database migrations and database operations. These tasks are located in the namespace :ch.
Creates a ClickHouse database in the specified cluster.
rake ch:createThis task will create a ClickHouse database as defined in the configuration file with the option to specify the cluster using the ClickHouse.config.database.
Example:
ClickHouse.config do |config|
config.assign Rails.application.config_for(:clickhouse)
endCreates a migration tracking table for ClickHouse in PostgreSQL. This table will be used to track applied migrations for the ClickHouse database.
rake ch:create_migration_tableDrops the ClickHouse database and truncates the migration tracking table.
rake ch:dropRuns the migrations for the ClickHouse database from the db/migrate/clickhouse directory.
rake ch:migrateYou can specify a version to migrate to using the VERSION environment variable.
Rollbacks the migrations for the ClickHouse database to a specified version.
rake ch:rollback VERSION=<version_number>If no version is provided, it rolls back the last migration.
Drops, recreates, and runs all migrations for the ClickHouse database. This is useful for resetting the entire ClickHouse setup.
rake ch:resetRollbacks any missing migrations for the ClickHouse database by comparing applied migrations to the available migration files.
rake ch:rollback_missing_migrationsSeveral tasks have been added under the namespace :sequel to provide better management of migrations and rollbacks in Sequel. These tasks help in managing PostgreSQL and ClickHouse migrations.
Archives migration source code into a PostgreSQL table for tracking purposes. This task can now accept custom paths for migrations and source tables.
rake sequel:archive_migrations[migrations_path, migration_table_source]migrations_path: Path to the migration files (default isdb/migrate/*.rb).migration_table_source: Table to store migration source code (default is:schema_migrations_sources).
Rollbacks migrations that were applied but are no longer present in the current release. The task supports additional options such as custom migration paths, tables, and transaction settings.
rake sequel:rollback_archived_migrations[migrations_path, migration_table, migration_table_source, use_transactions]migrations_path: Path to the migration files (default isdb/migrate/*.rb).migration_table: Table used to track applied migrations (default is:schema_migrations).migration_table_source: Table storing migration source code (default is:schema_migrations_sources).use_transactions: Whether to use transactions for rolling back (default isfalse).
Rollbacks migrations that are absent in the current release when deploying to staging or production. This task helps ensure consistency between different versions.
rake sequel:rollback_missing_migrations[table, use_transactions]table: The table used to track migrations (optional).use_transactions: Whether to use transactions during rollback (default isfalse).
This task specifically helps during deployment by rolling back any migrations that are not present in the current release.
rake sequel:rollback_missing_migrations[table, use_transactions]table: The table used to track migrations (optional).use_transactions: Whether or not to use transactions when rolling back (optional).
Released under MIT License.
Created by Team Umbrellio.
