Functions — github.com/ClickHouse/clickhouse-rs

hub / github.com/ClickHouse/clickhouse-rs / functions

Functions959 in github.com/ClickHouse/clickhouse-rs

⨍ Functions 959◇ Types & classes 219

↓ 318 callersMethodquery

Starts a new SELECT/DDL query.

src/lib.rs:518

↓ 134 callersMethodexecute

Executes the query.

src/query.rs:62

↓ 86 callersMethodwith_setting

Used to specify settings that will be passed to all queries. # Example ``` # use clickhouse::Client; Client::default().with_setting("allow_nondetermi

src/lib.rs:336

↓ 85 callersMethodbind

(mut self, value: impl Bind)

src/query.rs:56

↓ 80 callersMethodwrite

Serializes the provided row into an internal buffer. Once the buffer is full, it's sent to a background task writing to the socket. Close to: ```ign

src/insert.rs:175

↓ 76 callersFunctiondefault

()

src/http_client.rs:46

↓ 75 callersMethodend

Ends `INSERT`, the server starts processing the data. Succeeds if the server returns 200, that means the `INSERT` was handled successfully, including

src/insert.rs:230

↓ 45 callersMethodserialize

(&self, serializer: S)

src/types/int256.rs:131

↓ 37 callersMethodwith_url

Specifies ClickHouse's url. Should point to HTTP endpoint. Automatically [clears the metadata cache][Self::clear_cached_metadata] for this instance o

src/lib.rs:149

↓ 36 callersMethodnext

Emits the next row. The result is unspecified if it's called after `Err` is returned. # Cancel safety This method is cancellation safe.

src/cursors/row.rs:103

↓ 36 callersMethodparam

Specify server side parameter for query. In queries, you can reference params as {name: type} e.g. {val: Int32}.

src/query.rs:320

↓ 23 callersFunctioninsert_and_select

( client: &Client, table_name: &str, data: impl IntoIterator<Item = T>, )

tests/it/main.rs:207

↓ 22 callersFunctionnow

()

examples/enums.rs:72

↓ 20 callersFunctionselect_readonly_setting_query

(client: &Client)

tests/it/query_readonly.rs:171

↓ 19 callersFunctionget_client

()

tests/it/main.rs:129

↓ 19 callersMethodinsert

Starts a new INSERT statement. The table name will be escaped as a single identifier. To pass a fully qualified name, use [`Client::insert_unescaped(

src/lib.rs:463

↓ 18 callersMethodend

Flush the remaining data and finish the `INSERT` request. If no data has been written, no request will be sent. # Not Cancel-Safe If this method is

ext-arrow/src/lib.rs:238

↓ 18 callersMethodreschedule

(&mut self)

src/ticks.rs:52

↓ 18 callersMethodwrite

Write an Arrow [`RecordBatch`]. The batch is encoded to an internal buffer, which is flushed if it is already full. Because encoding the batch is sy

ext-arrow/src/lib.rs:192

↓ 17 callersMethodvalidate

(&'_ mut self, serde_type: SerdeType)

src/rowbinary/validation.rs:136

↓ 16 callersFunctioncreate_simple_table

(client: &Client, table_name: &str)

tests/it/main.rs:165

↓ 15 callersMethodwith_compression

Specifies a compression mode. See [`Compression`] for details. By default, `Lz4` is used if the `lz4` feature is enabled. # Examples ``` # use clickh

src/lib.rs:311

↓ 14 callersMethodget

Returns the raw string value for the given key, if present. Use this to access fields that are not yet covered by typed getters, e.g. fields added in

src/query_summary.rs:25

↓ 13 callersMethodcollect

Collect the full response into a vector of [`RecordBatch`]es. See also [`Self::collect_merged()`]. # Note: Not Cancel-Safe Cancelling the `Future` c

ext-arrow/src/lib.rs:438

↓ 13 callersMethodfetch_bytes

Executes the query, returning a [`BytesCursor`] to obtain results as raw bytes containing data in the [provided format]. [provided format]: https://c

src/query.rs:166

↓ 13 callersMethodfinish

(self)

src/sql/mod.rs:107

↓ 13 callersMethodinsert_formatted_with

Start an `INSERT` statement sending pre-formatted data. `sql` should be an `INSERT INTO ... FORMAT <format name>` statement. Any other type of statem

src/lib.rs:509

↓ 13 callersFunctionvalidate_impl

( root: &'serde DataTypeValidator<'caller, R>, column_data_type: &'caller DataTypeNode, serde_type

src/rowbinary/validation.rs:544

↓ 12 callersFunctionflush_query_log

(client: &Client)

tests/it/main.rs:187

↓ 11 callersMethodadd

(&self, handler: H)

src/test/mock.rs:100

↓ 11 callersMethodbind_arg

(&mut self, value: impl Bind)

src/sql/mod.rs:75

↓ 11 callersMethodsend

YAGNI?

src/request_body.rs:81

↓ 10 callersMethodextend

(&mut self, chunk: Bytes)

src/bytes_ext.rs:43

↓ 10 callersMethodrecord_in_current_span

Record this `Error` in the context of the current `tracing::Span`, setting the OpenTelemetry conventional fields if the `opentelemetry` feature is ena

src/error.rs:143

↓ 9 callersMethodexpect_client_mut

(&mut self)

src/insert_formatted.rs:105

↓ 9 callersMethodfetch_arrow

(self)

ext-arrow/src/lib.rs:118

↓ 9 callersMethodget_u64

(&self, key: &str)

src/query_summary.rs:65

↓ 9 callersMethodwith_roles

Configure the [roles] to use when executing statements with this `Client` instance. Overrides any roles previously set by this method or [`Client::wi

src/lib.rs:256

↓ 8 callersMethodadvance

(&mut self, n: usize)

src/bytes_ext.rs:36

↓ 8 callersMethodcommit

Checks limits and ends the current `INSERT` if they are reached.

src/inserter.rs:327

↓ 8 callersFunctioncreate_table

(client: &Client)

tests/it/insert_formatted.rs:332

↓ 8 callersMethodfetch_all

Executes the query and returns all the generated results, collected into a Vec. Note that `T` must be owned.

src/query.rs:148

↓ 8 callersMethodget_current_column_name_and_type

(&self)

src/rowbinary/validation.rs:81

↓ 8 callersFunctionput_leb128

(mut buffer: impl BufMut, mut value: u64)

types/src/leb128.rs:33

↓ 8 callersMethodremaining

(&self)

src/bytes_ext.rs:24

↓ 8 callersMethodset_setting

Set a setting on this instance of [`Client`]. Returns the previous value for the setting, if one was set.

src/lib.rs:422

↓ 8 callersFunctionverify_insert

(client: &Client)

tests/it/insert_formatted.rs:364

↓ 8 callersMethodwith_access_token

A JWT access token to authenticate with ClickHouse. JWT token authentication is supported in ClickHouse Cloud only. Should not be called after [`Clien

src/lib.rs:284

↓ 8 callersMethodwith_password

Specifies a password. # Panics If called after [`Client::with_access_token`]. # Examples ``` # use clickhouse::Client; let client = Client::default(

src/lib.rs:220

↓ 8 callersMethodwith_user

Specifies a user. # Panics If called after [`Client::with_access_token`]. # Examples ``` # use clickhouse::Client; let client = Client::default().wi

src/lib.rs:195

↓ 8 callersMethodwith_validation

Enables or disables [`Row`] data types validation against the database schema at the cost of performance. Validation is enabled by default, and in thi

src/lib.rs:549

↓ 7 callersMethodcollect_merged

Collect the full response and merge it into a single [`RecordBatch`]. This generally requires copying the full dataset into a new allocation, so this

ext-arrow/src/lib.rs:457

↓ 7 callersMethoderr_on_schema_mismatch

( &'serde self, data_type: &DataTypeNode, serde_type: &SerdeType, is_inner: bo

src/rowbinary/validation.rs:89

↓ 7 callersMethodinner

( &mut self, serde_type: SerdeType, )

src/rowbinary/de.rs:81

↓ 7 callersFunctionprepare_database

(db_name: &str)

tests/it/main.rs:411

↓ 7 callersMethodrun

( &self, f: impl Future<Output = Result<Duration>> + Send + 'static, )

benches/common.rs:110

↓ 7 callersFunctionserialize_row_binary

Serializes `row` using the `RowBinary` format and writes to `buffer`.

src/rowbinary/ser.rs:17

↓ 7 callersMethodsummary

(&self)

src/cursors/row.rs:199

↓ 6 callersMethodbuffered_with_capacity

Wrap this `InsertFormatted` with a buffer of a given size. The returned type also implements [`AsyncWrite`]. If `capacity == 0`, the buffer is flush

src/insert_formatted.rs:294

↓ 6 callersFunctioncompress

(uncompressed: &[u8])

src/compression/lz4.rs:159

↓ 6 callersFunctiondeserialize

(deserializer: D)

src/serde.rs:64

↓ 6 callersFunctionexecute_statements

(client: &Client, statements: &[&str])

tests/it/main.rs:196

↓ 6 callersMethodinserter

(&self, table: &str)

src/lib.rs:489

↓ 6 callersMethodread_size

(&mut self)

src/rowbinary/de.rs:104

↓ 6 callersMethodset_period

(&mut self, period: Option<Duration>)

src/ticks.rs:35

↓ 6 callersMethodslice

(&self)

src/bytes_ext.rs:18

↓ 6 callersMethodspan

(&self)

src/insert_formatted.rs:276

↓ 6 callersMethodwith_mock

(mut self, mock: &test::Mock)

src/lib.rs:601

↓ 6 callersMethodwith_product_info

Specifies the product name and version that will be included in the default User-Agent header. Multiple products are supported. This could be useful f

src/lib.rs:391

↓ 5 callersMethodclear_roles

(&mut self)

src/lib.rs:587

↓ 5 callersMethoddeserialize

(deserializer: D)

src/types/int256.rs:153

↓ 5 callersFunctionensure_size

(buffer: impl Buf, size: usize)

src/rowbinary/utils.rs:7

↓ 5 callersMethodis_enabled

(&self)

src/compression/mod.rs:67

↓ 5 callersFunctionread_leb128

(mut buffer: impl Buf)

types/src/leb128.rs:7

↓ 5 callersMethodto_le_bytes

(self)

src/types/int256.rs:86

↓ 5 callersMethodwith_max_rows

The maximum number of rows in one `INSERT` statement. In order to reduce overhead of merging small parts by ClickHouse, use larger values (e.g. 100_0

src/inserter.rs:124

↓ 4 callersMethodas_bnum

(&self)

src/types/int256.rs:105

↓ 4 callersMethodcmp

(&self, other: &Self)

src/types/int256.rs:47

↓ 4 callersFunctioncreate_table

(client: &Client)

tests/it/inserter.rs:23

↓ 4 callersFunctiondeserialize_row

Deserializes a row from `input` with a row encoded in `RowBinary`. If the optional metadata ([`RowMetadata`]) parsed from `RowBinaryWithNamesAndTypes

src/rowbinary/de.rs:26

↓ 4 callersFunctiondo_deserialize

(deserializer: D, mul: i128)

src/serde.rs:644

↓ 4 callersFunctiondo_serialize

(dt: &OffsetDateTime, div: i128, serializer: S)

src/serde.rs:633

↓ 4 callersMethoderror

(&mut self, err: impl Display)

src/sql/mod.rs:134

↓ 4 callersFunctionget_cloud_url

()

tests/it/main.rs:145

↓ 4 callersFunctionidentifier

See https://clickhouse.tech/docs/en/sql-reference/syntax/#syntax-identifiers

src/sql/escape.rs:13

↓ 4 callersMethodis_human_readable

(&self)

src/sql/ser.rs:281

↓ 4 callersMethodnext

Read the next batch of records. Cancel-safe.

ext-arrow/src/lib.rs:427

↓ 4 callersFunctionput_rbwnat_columns_header

( columns: &[Column], mut buffer: impl BufMut, )

types/src/lib.rs:60

↓ 4 callersFunctionrandom_str

()

examples/data_types_derive_simple.rs:285

↓ 4 callersMethodread_slice

(&mut self, size: usize)

src/rowbinary/de.rs:97

↓ 4 callersFunctionrequire_env_var

(name: &str)

tests/it/main.rs:141

↓ 4 callersFunctionrun_fetch

(query: Query)

tests/it/query_readonly.rs:175

↓ 4 callersFunctionrun_fetch_all

(query: Query)

tests/it/query_readonly.rs:208

↓ 4 callersFunctionrun_fetch_bytes

(query: Query)

tests/it/query_readonly.rs:190

↓ 4 callersFunctionrun_fetch_one

(query: Query)

tests/it/query_readonly.rs:200

↓ 4 callersFunctionrun_fetch_optional

(query: Query)

tests/it/query_readonly.rs:204

↓ 4 callersFunctionselect_rows

( client: Client, iters: u64, compression: Compression, validation: bool,

benches/mocked_select.rs:96

↓ 4 callersFunctionserialize

(ipv4: &Ipv4Addr, serializer: S)

src/serde.rs:57

↓ 4 callersMethodserialize_newtype_struct

( mut self, name: &'static str, value: &T, )

src/sql/ser.rs:200

↓ 4 callersMethodset_roles

(&mut self, roles: impl IntoIterator<Item = impl Into<String>>)

src/lib.rs:581

next →1–100 of 959, ranked by callers