Class: Sequel::MySQL::Dataset
- Includes:
- DatasetMethods, StoredProcedures
- Defined in:
- lib/sequel_core/adapters/mysql.rb
Overview
Dataset class for MySQL datasets accessed via the native driver.
Defined Under Namespace
Modules: CallableStatementMethods, PreparedStatementMethods, StoredProcedureMethods
Constant Summary
Constants included from DatasetMethods
Sequel::MySQL::DatasetMethods::BOOL_FALSE, Sequel::MySQL::DatasetMethods::BOOL_TRUE, Sequel::MySQL::DatasetMethods::CAST_TYPES, Sequel::MySQL::DatasetMethods::COMMA_SEPARATOR, Sequel::MySQL::DatasetMethods::TIMESTAMP_FORMAT
Constants inherited from Dataset
Dataset::AND_SEPARATOR, Dataset::BOOL_FALSE, Dataset::BOOL_TRUE, Dataset::COLUMN_CHANGE_OPTS, Dataset::COLUMN_REF_RE1, Dataset::COLUMN_REF_RE2, Dataset::COLUMN_REF_RE3, Dataset::COMMA_SEPARATOR, Dataset::COUNT_FROM_SELF_OPTS, Dataset::COUNT_OF_ALL_AS_COUNT, Dataset::DATASET_CLASSES, Dataset::MUTATION_METHODS, Dataset::NOTIMPL_MSG, Dataset::NULL, Dataset::N_ARITY_OPERATORS, Dataset::PREPARED_ARG_PLACEHOLDER, Dataset::QUESTION_MARK, Dataset::SELECT_CLAUSE_ORDER, Dataset::STOCK_COUNT_OPTS, Dataset::STOCK_TRANSFORMS, Dataset::TWO_ARITY_OPERATORS, Dataset::WILDCARD
Instance Attribute Summary
Attributes inherited from Dataset
#db, #identifier_input_method, #identifier_output_method, #opts, #quote_identifiers, #row_proc
Instance Method Summary collapse
-
#call(type, bind_arguments = {}, values = nil) ⇒ Object
MySQL is different in that it supports prepared statements but not bound variables outside of prepared statements.
-
#delete(opts = nil) ⇒ Object
Delete rows matching this dataset.
-
#fetch_rows(sql) ⇒ Object
Yield all rows matching this dataset.
-
#insert(*values) ⇒ Object
Insert a new value into this dataset.
-
#prepare(type, name = nil, values = nil) ⇒ Object
Store the given type of prepared statement in the associated database with the given name.
-
#replace(*args) ⇒ Object
Replace (update or insert) the matching row.
-
#update(*args) ⇒ Object
Update the matching rows.
Methods included from DatasetMethods
#cast_sql, #complex_expression_sql, #delete_sql, #full_text_search, #having, #insert_default_values_sql, #join_table, #join_type_sql, #multi_insert_sql, #quoted_identifier, #replace_sql, #update_sql
Methods inherited from Dataset
#<<, #[], #[]=, #add_graph_aliases, #aliased_expression_sql, #all, #and, #array_sql, #as, #avg, #case_expression_sql, #cast_sql, #clone, #column_all_sql, #columns, #columns!, #complex_expression_sql, #count, #create_or_replace_view, #create_view, dataset_classes, #def_mutation_method, def_mutation_method, #delete_sql, #each, #each_page, #empty?, #except, #exclude, #exists, #filter, #first, #first_source, #from, #from_self, #function_sql, #get, #graph, #grep, #group, #group_and_count, #having, inherited, #initialize, #insert_multiple, #insert_sql, #inspect, #intersect, #interval, #invert, #irregular_function_sql, #join_clause_sql, #join_on_clause_sql, #join_table, #join_using_clause_sql, #last, #limit, #literal, #map, #max, #min, #model_classes, #multi_insert, #multi_insert_sql, #naked, #or, #order, #order_more, #ordered_expression_sql, #paginate, #placeholder_literal_string_sql, #polymorphic_key, #print, #qualified_identifier_sql, #query, #quote_identifier, #quote_identifiers?, #quote_schema_table, #quoted_identifier, #range, #reverse_order, #schema_and_table, #select, #select_all, #select_more, #select_sql, #server, #set, #set_defaults, #set_graph_aliases, #set_model, #set_overrides, #single_record, #single_value, #sql, #subscript_sql, #sum, #symbol_to_column_ref, #table_exists?, #to_csv, #to_hash, #transform, #transform_load, #transform_save, #unfiltered, #union, #uniq, #unordered, #upcase_identifiers=, #upcase_identifiers?, #update_sql, #with_sql
Methods included from Enumerable
Constructor Details
This class inherits a constructor from Sequel::Dataset
Instance Method Details
#call(type, bind_arguments = {}, values = nil) ⇒ Object
MySQL is different in that it supports prepared statements but not bound variables outside of prepared statements. The default implementation breaks the use of subselects in prepared statements, so extend the temporary prepared statement that this creates with a module that fixes it.
272 273 274 275 276 |
# File 'lib/sequel_core/adapters/mysql.rb', line 272 def call(type, bind_arguments={}, values=nil) ps = to_prepared_statement(type, values) ps.extend(CallableStatementMethods) ps.call(bind_arguments) end |
#delete(opts = nil) ⇒ Object
Delete rows matching this dataset
279 280 281 |
# File 'lib/sequel_core/adapters/mysql.rb', line 279 def delete(opts = nil) execute_dui(delete_sql(opts)){|c| c.affected_rows} end |
#fetch_rows(sql) ⇒ Object
Yield all rows matching this dataset
284 285 286 287 288 289 290 291 292 293 294 295 |
# File 'lib/sequel_core/adapters/mysql.rb', line 284 def fetch_rows(sql) execute(sql) do |r| column_types = [] @columns = r.fetch_fields.map{|f| column_types << f.type; output_identifier(f.name)} while row = r.fetch_row h = {} @columns.each_with_index {|f, i| h[f] = convert_type(row[i], column_types[i])} yield h end end self end |
#insert(*values) ⇒ Object
Insert a new value into this dataset
298 299 300 |
# File 'lib/sequel_core/adapters/mysql.rb', line 298 def insert(*values) execute_dui(insert_sql(*values)){|c| c.insert_id} end |
#prepare(type, name = nil, values = nil) ⇒ Object
Store the given type of prepared statement in the associated database with the given name.
304 305 306 307 308 309 310 311 312 |
# File 'lib/sequel_core/adapters/mysql.rb', line 304 def prepare(type, name=nil, values=nil) ps = to_prepared_statement(type, values) ps.extend(PreparedStatementMethods) if name ps.prepared_statement_name = name db.prepared_statements[name] = ps end ps end |
#replace(*args) ⇒ Object
Replace (update or insert) the matching row.
315 316 317 |
# File 'lib/sequel_core/adapters/mysql.rb', line 315 def replace(*args) execute_dui(replace_sql(*args)){|c| c.insert_id} end |
#update(*args) ⇒ Object
Update the matching rows.
320 321 322 |
# File 'lib/sequel_core/adapters/mysql.rb', line 320 def update(*args) execute_dui(update_sql(*args)){|c| c.affected_rows} end |