Clojure.java.jdbc数据操作完全指南：CRUD操作详解
Clojure.java.jdbc数据操作完全指南CRUD操作详解【免费下载链接】java.jdbcJDBC from Clojure (formerly clojure.contrib.sql)项目地址: https://gitcode.com/gh_mirrors/ja/java.jdbcClojure.java.jdbc是一个强大的Clojure数据库访问库它为Java JDBC提供了简洁优雅的Clojure包装。无论您是Clojure新手还是有经验的开发者掌握这个库的CRUD操作都是高效进行数据库编程的关键。本文将详细介绍如何使用Clojure.java.jdbc进行创建、读取、更新和删除操作帮助您快速上手数据库开发。 快速入门与数据库连接首先您需要在项目中添加依赖。对于Leiningen项目在project.clj文件中添加[org.clojure/java.jdbc 0.8.0]对于deps.edn项目org.clojure/java.jdbc {:mvn/version 0.8.0}建立数据库连接非常简单。Clojure.java.jdbc支持多种数据库连接方式(require [clojure.java.jdbc :as j]) ;; 使用dbtype和dbname的简洁方式 (def mysql-db {:dbtype mysql :dbname myapp :user username :password secret}) ;; PostgreSQL连接示例 (def pg-db {:dbtype postgresql :dbname mydatabase :host localhost :port 5432 :user myuser :password secret}) ;; SQLite内存数据库 (def sqlite-db {:dbtype sqlite :dbname :memory:}) ;; 使用连接字符串 (def db-uri {:connection-uri jdbc:mysql://localhost:3306/myapp?userrootpasswordsecret}) 创建数据Create插入单条记录使用insert!函数插入单条记录非常简单;; 插入单条记录返回生成的键 (j/insert! mysql-db :users {:name 张三 :email zhangsanexample.com :age 25}) ;; ({:generated_key 1}) ;; 指定列插入 (j/insert! mysql-db :users [:name :email] [李四 lisiexample.com])批量插入多条记录对于批量插入使用insert-multi!函数;; 批量插入多条记录 (j/insert-multi! mysql-db :users [{:name 王五 :email wangwuexample.com :age 30} {:name 赵六 :email zhaoliuexample.com :age 28} {:name 孙七 :email sunqiexample.com :age 35}]) ;; ({:generated_key 2} {:generated_key 3} {:generated_key 4}) ;; 批量插入指定列的值 (j/insert-multi! mysql-db :users [:name :email] [[周八 zhoubaexample.com] [吴九 wujiuexample.com] [郑十 zhengshiexample.com]])使用execute!执行SQL插入您也可以直接执行SQL语句(j/execute! mysql-db [INSERT INTO users (name, email, age) VALUES (?, ?, ?) 张三 zhangsanexample.com 25]) 读取数据Read基本查询操作query函数是读取数据的核心;; 查询所有用户 (j/query mysql-db [SELECT * FROM users]) ;; ({:id 1, :name 张三, :email zhangsanexample.com, :age 25} ;; {:id 2, :name 李四, :email lisiexample.com, :age 28}) ;; 带参数的查询 (j/query mysql-db [SELECT * FROM users WHERE age ? 30]) ;; ({:id 3, :name 孙七, :email sunqiexample.com, :age 35}) ;; 使用命名参数某些数据库支持 (j/query mysql-db [SELECT * FROM users WHERE name :name {:name 张三}])查询结果处理Clojure.java.jdbc提供了强大的结果处理选项;; 只获取特定字段 (j/query mysql-db [SELECT name, email FROM users WHERE age ? 30] {:row-fn :name}) ;; (孙七) ;; 使用结果集函数 (j/query mysql-db [SELECT * FROM users] {:result-set-fn count}) ;; 4 ;; 结合使用row-fn和result-set-fn (j/query mysql-db [SELECT * FROM users WHERE age ? 25] {:row-fn #(select-keys % [:name :email]) :result-set-fn vec}) ;; [{:name 李四, :email lisiexample.com} ;; {:name 孙七, :email sunqiexample.com}]便捷查询函数Clojure.java.jdbc提供了几个便捷的查询函数;; 根据ID查询单条记录 (j/get-by-id mysql-db :users 1) ;; {:id 1, :name 张三, :email zhangsanexample.com, :age 25} ;; 根据多个条件查询 (j/find-by-keys mysql-db :users {:age 30}) ;; ({:id 3, :name 王五, :email wangwuexample.com, :age 30}) ;; 带排序的查询 (j/find-by-keys mysql-db :users {:age 30} {:order-by [:name]}) ;; 按姓名排序的结果可减少查询Reducible Queries对于大数据集可以使用reducible-query进行流式处理;; 使用reduce处理查询结果 (reduce (fn [total user] ( total (:age user))) 0 (j/reducible-query mysql-db SELECT * FROM users)) ;; 所有用户年龄的总和 ;; 使用transducer处理 (transduce (map :age) (j/reducible-query mysql-db SELECT * FROM users))✏️ 更新数据Update更新单条记录使用update!函数更新数据;; 更新特定条件的记录 (j/update! mysql-db :users {:email zhangsan.newexample.com :age 26} [id ? 1]) ;; [1] 返回更新的行数 ;; 更新多个字段 (j/update! mysql-db :users {:age 31, :updated_at (java.time.LocalDateTime/now)} [name ? 王五])批量更新虽然Clojure.java.jdbc没有直接的批量更新函数但可以通过组合操作实现;; 批量更新多条记录 (doseq [user-id [1 2 3]] (j/update! mysql-db :users {:status active} [id ? user-id]))更新或插入Upsert实现更新或插入的逻辑(defn upsert-user [db user-id user-data] (j/with-db-transaction [conn db] (let [result (j/update! conn :users user-data [id ? user-id])] (if (zero? (first result)) (j/insert! conn :users (assoc user-data :id user-id)) result))))️ 删除数据Delete删除单条记录使用delete!函数删除数据;; 删除特定条件的记录 (j/delete! mysql-db :users [id ? 1]) ;; [1] 返回删除的行数 ;; 删除多个条件匹配的记录 (j/delete! mysql-db :users [age ? AND status ? 18 inactive])清空表数据清空整个表的数据;; 删除所有记录 (j/delete! mysql-db :users []) ;; 返回删除的总行数 ;; 或者使用TRUNCATE性能更好 (j/execute! mysql-db [TRUNCATE TABLE users]) 事务管理Clojure.java.jdbc提供了强大的事务支持;; 基本事务使用 (j/with-db-transaction [tx mysql-db] (j/insert! tx :orders {:user_id 1 :amount 100}) (j/update! tx :users {:balance #sql balance - 100} [id ? 1]) ;; 如果这里抛出异常所有操作都会回滚 {:status :success}) ;; 指定事务隔离级别 (j/with-db-transaction [tx mysql-db {:isolation :serializable}] (j/query tx [SELECT * FROM users FOR UPDATE]) ;; 执行其他需要序列化隔离级别的操作 ) 高级查询技巧分页查询;; MySQL分页 (j/query mysql-db [SELECT * FROM users ORDER BY id LIMIT ? OFFSET ? 10 20]) ;; PostgreSQL分页 (j/query pg-db [SELECT * FROM users ORDER BY id LIMIT ? OFFSET ? 10 20])连接查询;; 内连接查询 (j/query mysql-db [SELECT u.name, o.amount, o.created_at FROM users u INNER JOIN orders o ON u.id o.user_id WHERE u.status ? active]) ;; 左连接查询 (j/query mysql-db [SELECT u.name, COUNT(o.id) as order_count FROM users u LEFT JOIN orders o ON u.id o.user_id GROUP BY u.id ORDER BY order_count DESC])聚合查询;; 统计查询 (j/query mysql-db [SELECT COUNT(*) as total_users, AVG(age) as avg_age, MIN(age) as min_age, MAX(age) as max_age FROM users]) ;; 分组统计 (j/query mysql-db [SELECT status, COUNT(*) as count FROM users GROUP BY status ORDER BY count DESC])️ 实用工具函数数据库元数据查询;; 获取表信息 (j/with-db-metadata [md mysql-db] (j/metadata-query md {:catalog nil :schema nil :table-name % :type [TABLE]})) ;; 获取列信息 (j/with-db-metadata [md mysql-db] (j/metadata-query md {:catalog nil :schema nil :table-name users :column-name %}))DDL操作;; 创建表 (j/db-do-commands mysql-db (j/create-table-ddl :users [[:id :int PRIMARY KEY AUTO_INCREMENT] [:name VARCHAR(255) NOT NULL] [:email VARCHAR(255) UNIQUE NOT NULL] [:age :int] [:created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP]])) ;; 删除表 (j/db-do-commands mysql-db (j/drop-table-ddl :users)) ;; 创建索引 (j/db-do-commands mysql-db [CREATE INDEX idx_users_email ON users(email)]) 自定义类型处理Clojure.java.jdbc支持自定义类型转换;; 自定义SQL值转换 (extend-protocol j/ISQLValue java.time.LocalDate (sql-value [v] (java.sql.Date/valueOf v))) ;; 自定义结果集读取 (extend-protocol j/IResultSetReadColumn java.sql.Date (result-set-read-column [v _ _] (.toLocalDate v))) ;; 使用自定义类型 (j/insert! mysql-db :events {:title 会议 :date (java.time.LocalDate/of 2024 12 25)}) 性能优化建议1. 使用连接池;; 使用HikariCP连接池示例 (def db-spec {:datasource (doto (HikariDataSource.) (.setJdbcUrl jdbc:mysql://localhost/myapp) (.setUsername user) (.setPassword password) (.setMaximumPoolSize 10))})2. 批量操作优化;; 使用事务批量插入 (j/with-db-transaction [tx mysql-db] (doseq [batch (partition-all 1000 large-data-set)] (j/insert-multi! tx :logs batch)))3. 查询优化;; 只选择需要的列 (j/query mysql-db [SELECT id, name FROM users WHERE status ? active] {:fetch-size 1000}) ;; 设置合适的fetch size ;; 使用预处理语句 (let [stmt (j/prepare-statement mysql-db SELECT * FROM users WHERE age ? AND status ? {:fetch-size 500})] (j/query mysql-db [stmt 25 active])) 实际应用示例用户管理系统示例(ns myapp.users (:require [clojure.java.jdbc :as j])) (def db {:dbtype postgresql :dbname myapp :host localhost :user admin :password secret}) (defn create-user [user-data] (j/insert! db :users user-data)) (defn get-user [user-id] (j/get-by-id db :users user-id)) (defn update-user [user-id updates] (j/update! db :users updates [id ? user-id])) (defn delete-user [user-id] (j/delete! db :users [id ? user-id])) (defn search-users [criteria options] (let [where-clause (if (seq criteria) (str WHERE (clojure.string/join AND (map #(str (name %) ?) (keys criteria)))) ) params (vals criteria) sql (str SELECT * FROM users where-clause (if-let [order (:order-by options)] (str ORDER BY (clojure.string/join , order)) ) (if-let [limit (:limit options)] (str LIMIT limit) ))] (j/query db (into [sql] params)))) 错误处理;; 基本的错误处理 (try (j/insert! db :users {:email existingexample.com}) (catch java.sql.SQLException e (if (.contains (.getMessage e) Duplicate entry) (println 用户已存在) (throw e)))) ;; 使用事务确保数据一致性 (j/with-db-transaction [tx db] (try (j/insert! tx :orders order-data) (j/update! tx :users {:balance #sql balance - ? (:amount order-data)} [id ? (:user-id order-data)]) (catch Exception e (println 订单创建失败: (.getMessage e)) (throw e)))) 总结Clojure.java.jdbc为Clojure开发者提供了一个强大而简洁的数据库操作接口。通过本文的详细介绍您应该已经掌握了基本CRUD操作创建、读取、更新和删除数据高级查询技巧分页、连接、聚合查询事务管理确保数据一致性性能优化批量操作、连接池使用错误处理健壮的异常处理机制这个库的设计哲学是简单而强大它避免了过度抽象同时提供了足够的功能来满足大多数数据库操作需求。无论是小型项目还是大型企业应用Clojure.java.jdbc都是一个可靠的选择。记住良好的数据库实践包括始终使用参数化查询防止SQL注入合理使用事务保证数据一致性为频繁查询的字段创建索引定期备份重要数据现在您已经掌握了Clojure.java.jdbc的核心功能可以开始构建强大的数据库驱动的Clojure应用了【免费下载链接】java.jdbcJDBC from Clojure (formerly clojure.contrib.sql)项目地址: https://gitcode.com/gh_mirrors/ja/java.jdbc创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考
)
)
