📅 最后修改于: 2020-11-05 04:08:01 🧑 作者: Mango
为了使用数据库功能，请确保首先从以下URL下载jdbc文件： https://codeload.github.com/clojure/java.jdbc/zip/master
您会找到一个zip文件，其中包含Clojure具备连接数据库的必要驱动程序。解压缩zip文件后，请确保将解压缩的位置添加到您的类路径中。
用于数据库连接的主要文件是位于clojure / java位置的名为jdbc.clj的文件。
clojure jdbc连接器支持各种数据库，以下是其中一些。
在我们的示例中，我们将以MySQL DB为例。
关于数据库，在Clojure中可以进行以下操作。
连接到MySQL数据库之前，请确保以下内容-
您已经创建了数据库TESTDB。
您已经在TESTDB中创建了一个表EMPLOYEE。
该表包含字段FIRST_NAME，LAST_NAME，AGE，SEX和INCOME。
用户ID“ testuser”和密码“ test123”设置为访问TESTDB。
确保您已下载“ mysql jar文件”并将其添加到类路径。
您已经阅读了MySQL教程，以了解MySQL基础知识。
以下是在Clojure中创建连接的语法。
(def connection_name {
:subprotocol “protocol_name”
:subname “Location of mysql DB”
:user “username” :password “password” })
参数-‘connection_name’是要赋予连接的名称。 “ subprotocol”是用于连接的协议。默认情况下，我们将使用mysql协议。 “ subname”是与数据库名称一起连接到mysql db的URL。 “用户”是用于连接数据库的用户名。 “密码”是用于连接数据库的密码。
返回值-这将提供一个连接字符串，可在后续的mysql操作中使用。
以下示例显示了如何连接到信息模式中的表以及如何检索表中的所有数据。
(ns test.core
(:require [clojure.java.jdbc :as sql]))
(defn -main []
(def mysql-db {
:subprotocol "mysql"
:subname "//127.0.0.1:3306/information_schema"
:user "root"
:password "shakinstev"})
(println (sql/query mysql-db
["select table_name from tables"]
:row-fn :table_name)))
查询任何数据库上的数据都意味着从数据库中获取一些有用的信息。建立数据库连接后，即可准备对该数据库进行查询。以下是使用Clojure查询数据的语法。
clojure.java.jdbc/query dbconn
["query"]
:row-fn :sequence
参数-‘dbconn’是用于连接到数据库的连接的名称。 ‘query’是用于从数据库中获取数据的查询字符串。默认情况下，“：sequence”是从数据库中获取的所有数据行，并作为序列返回。然后可以对序列进行必要的操作，以查看已获取了哪些数据。
返回值-这将返回一个序列，其中将包含来自查询操作的数据行。
下面的示例显示如何连接到employee表并获取表中行的first_name列。
(ns test.core
(:require [clojure.java.jdbc :as sql]))
(defn -main []
(def mysql-db {
:subprotocol "mysql"
:subname "//127.0.0.1:3306/testdb"
:user "root"
:password "shakinstev"})
(println (sql/query mysql-db
["select first_name from employee"]
:row-fn :first_name)))
从上面的代码，我们可以看到
“从雇员中选择名字”的查询作为查询字符串传递。
：first_name是序列，作为获取操作的结果返回。
如果我们假设数据库中只有一行包含John的first_name值，则下面是上述程序的输出。
(John)
要在数据库表中创建记录时需要它。以下是可使用Clojure插入数据的语法。这是通过使用“插入！”完成的。函数。
clojure.java.jdbc/insert!
:table_name {:column_namen columnvalue}
参数-‘：table_name’是需要在其中插入表的名称。 ‘{：column_namen columnvalue}’是所有列名和值的映射，需要将它们作为表格中的一行添加。
返回值-如果插入成功，它将返回nil。
下面的示例演示如何将记录插入到testdb数据库的employee表中。
(ns test.core
(:require [clojure.java.jdbc :as sql]))
(defn -main []
(def mysql-db {
:subprotocol "mysql"
:subname "//127.0.0.1:3306/testdb"
:user "root"
:password "shakinstev"})
(sql/insert! mysql-db
:employee {:first_name "John" :last_name "Mark" :sex "M" :age 30 :income 30}))
如果现在检查MySQL数据库和employee表，您将看到上面的行将成功插入到表中。
可以使用“删除！”从表中删除行。函数。以下是有关如何执行此操作的语法。
clojure.java.jdbc/delete!
:table_name [condition]
参数-‘：table_name’是需要在其中插入表的名称。 “条件”是用于确定需要从表中删除哪一行的条件。
返回值-这将返回删除的行数。
下面的示例显示如何从testdb数据库中的employee表中删除记录。该示例根据年龄等于30的条件从表中删除一行。
(ns test.core
(:require [clojure.java.jdbc :as sql]))
(defn -main []
(def mysql-db {
:subprotocol "mysql"
:subname "//127.0.0.1:3306/testdb"
:user "root"
:password "shakinstev"})
(println (sql/delete! mysql-db
:employee ["age = ? " 30])))
如果您有一条记录，其行的年龄等于30，则该行将被删除。
可以使用“ update！”从表中更新行。函数。以下是有关如何执行此操作的语法。
clojure.java.jdbc/update!
:table_name
{setcondition}
[condition]
参数-‘：table_name’是需要在其中插入表的名称。 “设置条件”是需要更新的列(如地图所述)。 “条件”是用于确定需要从表中删除哪一行的条件。
返回值-这将返回更新的行数。
下面的示例显示如何从testdb数据库中的employee表中删除记录。该示例基于年龄等于30的条件从表中更新一行，并将收入值更新为40。
(ns test.core
(:require [clojure.java.jdbc :as sql]))
(defn -main []
(def mysql-db {
:subprotocol "mysql"
:subname "//127.0.0.1:3306/testdb"
:user "root"
:password "shakinstev"})
(println (sql/update! mysql-db
:employee
{:income 40}
["age = ? " 30])))
如果您有一条记录，其行的年龄等于30，则该行将被更新，其中收入值将设置为40。
事务是确保数据一致性的机制。事务具有以下四个属性-
原子性-事务完成还是什么都没有发生。
一致性-事务必须以一致状态开始，并使系统保持一致状态。
隔离-交易的中间结果在当前交易之外不可见。
持久性-提交事务后，即使在系统出现故障后，效果也将持久。
以下示例显示了如何在Clojure中实现事务。任何需要在事务中执行的操作都必须嵌入“ with-dbtransaction”子句中。
(ns test.core
(:require [clojure.java.jdbc :as sql]))
(defn -main []
(def mysql-db {
:subprotocol "mysql"
:subname "//127.0.0.1:3306/testdb"
:user "root"
:password "shakinstev"})
(sql/with-db-transaction [t-con mysql-db]
(sql/update! t-con
:employee
{:income 40}
["age = ? " 30])))