• golang 连接 oracle 数据库 增删改查

     1，golang 连接 oracle 数据库

     2，增删改查

    1. /*
    2.  * @Author: lmy
    3.  * @Date: 2023-08-24 15:19:22
    4.  * @LastEditors: lmy
    5.  * @LastEditTime: 2023-08-24 16:23:58
    6.  * @FilePath: \golangOracleDemo\main.go
    7.  * @Description:  golang oracle 增删改查 DEMO
    8.  */
    9.  
    10. package main
    11.  
    12. import (
    13. 	"database/sql"
    14. 	"fmt"
    15. 	"strings"
    16. 	"time"
    17.  
    18. 	go_ora "github.com/sijms/go-ora/v2"
    19. )
    20.  
    21. var oracleDB *sql.DB //oracleDB  oracle数据库
    22.  
    23. func main() {
    24. 	var err error
    25.  
    26. 	// 演示的数据库表DDL
    27. 	//   CREATE TABLE "SYSTEM"."TABLE1"
    28. 	//    (	"ID" NUMBER(*,0) GENERATED ALWAYS AS IDENTITY MINVALUE 1 MAXVALUE 9999999999999999999999999999 INCREMENT BY 1 START WITH 1 CACHE 20 NOORDER  NOCYCLE  NOKEEP  NOSCALE  NOT NULL ENABLE,
    29. 	// 	"NAME" VARCHAR2(20 BYTE),
    30. 	// 	"AGE" NUMBER(*,0),
    31. 	// 	"PHONE" VARCHAR2(11 BYTE),
    32. 	// 	"BIRTHDAY" DATE
    33. 	//    ) PCTFREE 10 PCTUSED 40 INITRANS 1 MAXTRANS 255
    34. 	//  NOCOMPRESS LOGGING
    35. 	//   STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645
    36. 	//   PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1
    37. 	//   BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)
    38. 	//   TABLESPACE "SYSTEM" ;
    39.  
    40. 	// 传入数据库连接字符串
    41. 	// username/password@host:port/service_name
    42. 	//system:123456@192.168.168.152:1521/orcl.docker.internal
    43. 	//system:123456@192.168.168.152:1521/?SID=orcl
    44. 	port := 1521                          // 端口
    45. 	server := "192.168.168.152"           // Host
    46. 	serviceName := "orcl.docker.internal" // 连接名|服务名
    47. 	username := "system"                  // 用户名
    48. 	password := "123456"                  // 密码
    49. 	sid := "orcl"                         // SID
    50. 	connStr := ""
    51. 	//连接数据库的方式
    52. 	//方法1:简单连接
    53. 	connStr = go_ora.BuildUrl(server, port, serviceName, username, password, nil)
    54. 	fmt.Println("数据库链接1=>", connStr)
    55. 	//方法2:使用SID连接
    56. 	urlOptions := map[string]string{
    57. 		"SID": sid,
    58. 	}
    59. 	connStr = go_ora.BuildUrl(server, port, "", username, password, urlOptions)
    60. 	fmt.Println("数据库链接2=>", connStr)
    61.  
    62. 	oracleDB, err = CreateOracleSQLConnV2(connStr)
    63. 	if err != nil {
    64. 		fmt.Printf("连接数据库失败：%v \n", err)
    65. 		return
    66. 	}
    67. 	// 设置数据库链接 |  要数据库连链接创建成功 才能走下面的流程
    68.  
    69. 	//增
    70. 	var info TableInfo
    71. 	info.Name = "小明"
    72. 	info.Age = 11
    73. 	info.Birthday, _ = time.Parse("2006-01-02", "2012-08-08")
    74. 	if isOK, _ := addTableInfo(info); isOK {
    75. 		fmt.Println("新增数据成功", info)
    76. 	} else {
    77. 		fmt.Println("新增数据失败", info)
    78. 	}
    79.  
    80. 	//增
    81. 	info.Name = "大明"
    82. 	info.Age = 19
    83. 	var timeZero time.Time
    84. 	info.Birthday = timeZero
    85. 	//info.Birthday, _ = time.Parse("2006-01-02", "2004-09-08")
    86. 	isOK, err := addTableInfo(info)
    87. 	if err != nil {
    88. 		fmt.Println("新增数据异常", info, err)
    89. 	} else {
    90. 		if isOK {
    91. 			fmt.Println("新增数据成功", info)
    92. 		} else {
    93. 			fmt.Println("新增数据失败", info)
    94. 		}
    95. 	}
    96.  
    97. 	//根据名称和年龄搜查询单条数据
    98. 	info, err = sqlGetOneTableDataInfo("明", 18)
    99. 	if err != nil {
    100. 		fmt.Printf("根据ID查询单条数据失败：%v \n", err)
    101. 		return
    102. 	}
    103. 	fmt.Println("根据名称和年龄搜查询单条数据", info)
    104. 	//查询所有数据
    105. 	datas, err := sqlGetAllTableDataInfo()
    106. 	if err != nil {
    107. 		fmt.Printf("查询所有数据失败：%v \n", err)
    108. 		return
    109. 	}
    110. 	fmt.Println("查询所有数据=>", datas)
    111.  
    112. 	info.Name = "老明"
    113. 	info.Age = 20
    114. 	info.Birthday, _ = time.Parse("2006-01-02", "2003-05-06")
    115. 	//改
    116. 	if isOK := editTableInfo(info); isOK {
    117. 		fmt.Println("编辑数据成功", info)
    118. 	} else {
    119. 		fmt.Println("编辑数据失败", info)
    120. 	}
    121.  
    122. 	//查询所有数据
    123. 	datas, err = sqlGetAllTableDataInfo()
    124. 	if err != nil {
    125. 		fmt.Printf("查询所有数据失败：%v", err)
    126. 		return
    127. 	}
    128. 	fmt.Println("查询所有数据=>", datas)
    129. 	fmt.Println("删除数据=>", info.ID)
    130. 	// 删除
    131. 	deleteTableInfoByID(info.ID)
    132. 	fmt.Println()
    133. 	//查询所有数据
    134. 	datas, err = sqlGetAllTableDataInfo()
    135. 	if err != nil {
    136. 		fmt.Printf("查询所有数据失败：%v", err)
    137. 		return
    138. 	}
    139. 	fmt.Println("查询所有数据=>", datas)
    140.  
    141. 	//删除所有数据
    142. 	deleteTableInfo()
    143. 	fmt.Println("删除表所有数据")
    144.  
    145. 	//查询所有数据
    146. 	datas, err = sqlGetAllTableDataInfo()
    147. 	if err != nil {
    148. 		fmt.Printf("查询所有数据失败：%v", err)
    149. 		return
    150. 	}
    151. 	fmt.Println("查询所有数据=>", datas)
    152. }
    153.  
    154. // 添加表数据
    155. func addTableInfo(info TableInfo) (bool, error) {
    156. 	affect, err := ExecSQL(oracleDB, "INSERT INTO TABLE1( NAME,AGE,BIRTHDAY) VALUES(:name, :age,:brithday)", info.Name, info.Age, info.Birthday)
    157. 	if err != nil {
    158. 		fmt.Printf("添加数据失败：%v", err)
    159. 		return false, err
    160. 	}
    161. 	return affect > 0, nil
    162. }
    163.  
    164. // 编辑表数据
    165. func editTableInfo(info TableInfo) bool {
    166. 	affect, err := ExecSQL(oracleDB, "UPDATE TABLE1 SET NAME=:name,AGE=:age,BIRTHDAY=:brithday WHERE ID=:ID", info.Name, info.Age, info.Birthday, info.ID)
    167. 	if err != nil {
    168. 		fmt.Printf("修改数据失败：%v", err)
    169. 		return false
    170. 	}
    171. 	return affect > 0
    172. }
    173.  
    174. // 根据ID删除表数据
    175. func deleteTableInfoByID(id int) bool {
    176. 	affect, err := ExecSQL(oracleDB, "DELETE TABLE1 where ID = :id", id)
    177. 	if err != nil {
    178. 		fmt.Printf("根据ID删除数据失败：id:%v,%v", id, err)
    179. 		return false
    180. 	}
    181. 	return affect > 0
    182. }
    183.  
    184. // 删除表所有数据
    185. func deleteTableInfo() bool {
    186. 	affect, err := ExecSQL(oracleDB, "DELETE TABLE1 ")
    187. 	if err != nil {
    188. 		fmt.Printf("删除所有数据失败：%v", err)
    189. 		return false
    190. 	}
    191. 	return affect > 0
    192. }
    193.  
    194. // 表数据结构体
    195. type TableInfo struct {
    196. 	ID       int       //id,--ID
    197. 	Name     string    //NAME,--名称
    198. 	Age      int       //AGE,--年纪
    199. 	Birthday time.Time //BIRTHDAY,--生日
    200. }
    201.  
    202. // 根据ID查询单条数据
    203. func sqlGetOneTableDataInfo(name string, age int) (TableInfo, error) {
    204. 	//根据id查询名称
    205. 	var info TableInfo
    206. 	sqlStr := `select  ID, nvl(NAME,' ')  NAME, nvl(AGE,0) AGE, nvl(BIRTHDAY,'') BIRTHDAY  from TABLE1 where  NAME LIKE :name  AND AGE >= :p2 `
    207. 	err := oracleDB.QueryRow(sqlStr, "%"+name+"%", age).Scan(&info.ID, &info.Name, &info.Age, &info.Birthday)
    208. 	if err != nil {
    209. 		if err == sql.ErrNoRows { // 属于空查找
    210. 			fmt.Printf("查询 数据失败--没有符合条件的数据: \n ")
    211. 		}
    212. 		fmt.Printf("查询 数据失败: \nid=%v \nerr=%s", info.ID, err)
    213. 		return info, err
    214. 	}
    215. 	return info, err
    216. }
    217.  
    218. // 查询所有数据
    219. func sqlGetAllTableDataInfo() ([]TableInfo, error) {
    220. 	var data []TableInfo
    221. 	rows, err := oracleDB.Query("SELECT ID, NAME,AGE,BIRTHDAY FROM TABLE1")
    222. 	if err != nil {
    223. 		fmt.Printf("查询数据失败：%v \n", err)
    224. 		return data, err
    225. 	}
    226. 	defer rows.Close()
    227. 	var info TableInfo
    228. 	for rows.Next() { // 游标读取
    229. 		info = TableInfo{}
    230. 		err = rows.Scan(&info.ID, &info.Name, &info.Age, &info.Birthday)
    231. 		if err != nil {
    232. 			fmt.Printf("查询数据失败：%v \n", err)
    233. 		} else {
    234. 			data = append(data, info)
    235. 		}
    236. 	}
    237. 	return data, nil
    238. }
    239.  
    240. /*
    241. ExecSQL 通用语句
    243. 	参数：
    244. 	1. *sql.DB
    245. 	2. SQL语句  例子：UPDATE WX_USER_INFO SET wui_status = 20 WHERE wui_openid = :openid
    246. 							例子：INSERT INTO dbo.ALL_WEIXIN_MSG_LOG (awml_wxid,awml_send_openid,awml_msg_from,awml_msg_body,awml_addtime) VALUES(:wxid,:openid,:msgform,:msgbody,GETDATE())
    247. 	3. SQL语句参数参数  os7Cm1EygxiRF3Tox6FM1z11HiMc ,.........
    248. 	返回受影响行数affect和错误提示消息err
    249. */
    250. func ExecSQL(sqlBasis *sql.DB, sqlStr string, args ...interface{}) (int64, error) {
    251. 	affect := int64(-1)
    252. 	var result sql.Result
    253. 	var err error
    254. 	result, err = sqlBasis.Exec(sqlStr, args...)
    255. 	if err == nil {
    256. 		affect, _ = result.RowsAffected()
    257. 	}
    258. 	if affect == -1 { //执行失败
    259. 		err = fmt.Errorf("execSQLStr Err:%s\nsql:%s\ndata:%s", err, sqlStr, fmt.Sprintln(args...))
    260. 	}
    261. 	return affect, err
    262. }
    263.  
    264. /*
    265. CreateOracleSQLConnV2 用于创建数据库链接
    266. */
    267. func CreateOracleSQLConnV2(dbconfigdatastr string) (*sql.DB, error) {
    268. 	// 建立 Oracle
    269. 	sqldbdata, err := sql.Open("oracle", dbconfigdatastr)
    270. 	if err != nil {
    271. 		fmt.Printf("sql application pool：%s\n", err)
    272. 		return nil, err
    273. 	}
    274. 	// 测试创建链接是否成功
    275. 	err = sqldbdata.Ping()
    276. 	dbName := strings.Split(dbconfigdatastr, "/")[2]
    277. 	if err != nil {
    278. 		fmt.Printf("%s DB Ping err : %s\n", dbName, err)
    279. 		defer sqldbdata.Close()
    280. 	} else {
    281. 		fmt.Printf("The Sql link is successful - %s. \n", dbName)
    282. 	}
    283. 	return sqldbdata, err
    284. }

  • 相关阅读:
    form表单有大知识
    WPF 用户控件依赖注入赋值
    springboot基于微信小程序的驾校报名小程序+java+uinapp+Mysql+计算机毕业设计
    第九章认识Express模板
    CISAW应急服务:网络安全应急响应之路——从经验到认证的体会
    常见docker命令(二)-容器生命周期相关
    LeakCanary从使用到源码分析
    Android 解析包时出现问题 的解决方案（应用检查更新）
    idea模板设置
    【用unity实现100个游戏之16】Unity程序化生成随机2D地牢游戏2（附项目源码）
  • 原文地址：https://blog.csdn.net/lmy_loveF/article/details/132596184