广告位联系
返回顶部
分享到

如何使用beego orm在postgres中存储图片

Golang 来源:互联网 作者:佚名 发布时间:2023-12-03 15:35:04 人浏览
摘要

Postgres如何存储文件 postgres提供了两种不同的方式存储二进制,要么是使用bytea类型直接存储二进制,要么就是使用postgres的LargeObject功能;决定使用哪中方式更加适合你,就需要了解这

Postgres如何存储文件

postgres提供了两种不同的方式存储二进制,要么是使用bytea类型直接存储二进制,要么就是使用postgres的LargeObject功能;决定使用哪中方式更加适合你,就需要了解这两种存储方式有哪些限制

bytea类型

bytea类型在单列中虽然可以支持1GB的容量,但是还是不建议使用bytea去储存比较大的对象,因为它会占用大量的内存

下面通过一个例子来说明,假如现在要在一个表中存储图片名和该图片的数据,创建表如下:

1

CREATE TABLE images (imgname text, img bytea);

在表中插入一张图片:

1

2

3

4

5

6

7

8

File file = new File("myimage.gif");

FileInputStream fis = new FileInputStream(file);

PreparedStatement ps = conn.prepareStatement("INSERT INTO images VALUES (?, ?)");

ps.setString(1, file.getName());

ps.setBinaryStream(2, fis, file.length());

ps.executeUpdate();

ps.close();

fis.close();

上面的setBinaryStream就会将图片内容设置到img字段上面,也可以使用setBytes()直接设置图片的内容

接下来,从表中取出图片,代码如下:

1

2

3

4

5

6

7

8

9

10

11

PreparedStatement ps = con.prepareStatement("SELECT img FROM images WHERE imgname = ?");

ps.setString(1, "myimage.gif");

ResultSet rs = ps.executeQuery();

if (rs != null) {

    while (rs.next()) {

        byte[] imgBytes = rs.getBytes(1);

        // use the data in some way here

    }

    rs.close();

}

ps.close();

Large Object

Large Object就可以存储大文件,存储的方式是在单独的一张表中存储大文件,然后通过oid在当前表中进行引用;下面通过一个例子来解释:

1

CREATE TABLE imageslo (imgname text, imgoid oid);

首先是创建一张表,该表中第二个字段类型为oid,之后就是通过该字段引用大文件对象;下面我们在表中插入一张图片:

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

// All LargeObject API calls must be within a transaction block

conn.setAutoCommit(false);

// Get the Large Object Manager to perform operations with

LargeObjectManager lobj = ((org.postgresql.PGConnection)conn).getLargeObjectAPI();

// Create a new large object

int oid = lobj.create(LargeObjectManager.READ | LargeObjectManager.WRITE);

// Open the large object for writing

LargeObject obj = lobj.open(oid, LargeObjectManager.WRITE);

// Now open the file

File file = new File("myimage.gif");

FileInputStream fis = new FileInputStream(file);

// Copy the data from the file to the large object

byte buf[] = new byte[2048];

int s, tl = 0;

while ((s = fis.read(buf, 0, 2048)) > 0) {

    obj.write(buf, 0, s);

    tl += s;

}

// Close the large object

obj.close();

// Now insert the row into imageslo

PreparedStatement ps = conn.prepareStatement("INSERT INTO imageslo VALUES (?, ?)");

ps.setString(1, file.getName());

ps.setInt(2, oid);

ps.executeUpdate();

ps.close();

fis.close();

在代码中需要使用lobp.open打开一个大文件,然后将图片的内容写入这个对象当中;下面从大文件对象中读取这个图片:

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

// All LargeObject API calls must be within a transaction block

conn.setAutoCommit(false);

// Get the Large Object Manager to perform operations with

LargeObjectManager lobj = ((org.postgresql.PGConnection)conn).getLargeObjectAPI();

PreparedStatement ps = con.prepareStatement("SELECT imgoid FROM imageslo WHERE imgname = ?");

ps.setString(1, "myimage.gif");

ResultSet rs = ps.executeQuery();

if (rs != null) {

    while (rs.next()) {

        // Open the large object for reading

        int oid = rs.getInt(1);

        LargeObject obj = lobj.open(oid, LargeObjectManager.READ);

        // Read the data

        byte buf[] = new byte[obj.size()];

        obj.read(buf, 0, obj.size());

        // Do something with the data read here

        // Close the object

        obj.close();

    }

    rs.close();

}

ps.close();

需要注意的是,对于Large Object的操作都需要放在一个事务(Transaction)当中;如果要删除大文件所在行,在删除这行之后,还需要再执行删除大文件的操作

注:使用Large Object会有安全问题,连接到数据库的用户,即便没有包含大对象所在列的权限,也可以操作这个大对象

Beego orm如何存储图片

看完上面的postgres对于图片的存储,再来看下如何使用beego orm存储一张图片;在beego orm中支持了go的所有基础类型,但是不支持slice;所以,不能直接将[]byte映射到bytea字段上面

好在beego orm提供了一个Fielder接口,可以自定义类型,接口定义如下:

1

2

3

4

5

6

7

// Fielder define field info

type Fielder interface {

    String() string

    FieldType() int

    SetRaw(interface{}) error

    RawValue() interface{}

}

所以,现在就需要定义一个字节数组的类型,然后实现这些接口就好了,代码如下:

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

type ByteArrayField []byte

// set value

func (e *ByteArrayField) SetRaw(value interface{}) error {

    if value == nil {

        return nil

    }

    switch d := value.(type) {

    case []byte:

        *e = d

    case string:

        *e = []byte(d)

    default:

        return fmt.Errorf("[ByteArrayField] unsupported type")

    }

    return nil

}

func (e *ByteArrayField) RawValue() interface{} {

    return *e

}

// specified type

func (f *ByteArrayField) FieldType() int {

    return orm.TypeTextField

}

func (f *ByteArrayField) String() string {

    return string(*f)

}

然后,我们就可以在struct中进行映射了,如下:

1

2

3

4

type ImageModel struct{

    ImageName string `orm:"column(image_name)"`

    ImageData ByteArrayField `orm:"column(image_data);type(bytea)"`

}

这样就可以使用orm的接口操作imageModel,向数据库插入图片,或者从数据库读出图片的内容了


版权声明 : 本文内容来源于互联网或用户自行发布贡献,该文观点仅代表原作者本人。本站仅提供信息存储空间服务和不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权, 违法违规的内容, 请发送邮件至2530232025#qq.cn(#换@)举报,一经查实,本站将立刻删除。

您可能感兴趣的文章 :

原文链接 :
    Tag :
相关文章
  • Docker golang + ffmpeg执行命令失败
    您好,我正在使用以下 docker 映像: 1 from golang:alpine3.18 使用 ffmpeg:(可能在这里我遗漏了一些东西) 1 run apk add --no-cache ffmpeg 但是当尝试执
  • 如何使用beego orm在postgres中存储图片
    Postgres如何存储文件 postgres提供了两种不同的方式存储二进制,要么是使用bytea类型直接存储二进制,要么就是使用postgres的LargeObject功能;决
  • GoLang sync.Pool简介与用法
    一句话总结:保存和复用临时对象,减少内存分配,降低GC压力 sync.Pool是可伸缩的,也是并发安全的,其大小仅受限于内存大小。sync.Pool用
  • golang与pgsql交互的实现介绍

    golang与pgsql交互的实现介绍
    1、目的 通过读取配置文件获取pgsql用户名和密码及数据库和数据表,从而读取所需字段值。 2、代码架构 config/config.go:读取配置文件信息
  • Go语言中rune方法使用介绍

    Go语言中rune方法使用介绍
    1.byte类型 byte类型是uint8的别名,表示一个字节, 2.rune类型 rune类型是Go语言中的一个基本类型,其实就是一个int32的别名,主要用于表示一个
  • Go打包附件内容到执行文件的方法
    如果我们的应用在启动的时候需要对数据库进行初始化(比如建表等), 可以通过读取.sql文件内容直接执行. 但是, 这样会带出一个问题: 在发送
  • go连接kafka的实现教程
    要在Go语言中连接Kafka,需要使用Kafka的Go客户端库,例如sarama。sarama是一个纯Go实现的Kafka客户端库,提供了连接Kafka集群、发送和接收消息等
  • golang占位符的详细介绍
    xdm ,写 C/C++ 语言的时候有格式控制符,例如 %s , %d , %c , %p 等等 在写 golang 的时候,也是有对应的格式控制符,也叫做占位符,写这个占位
  • Go语言实现的微服务性能优化工具介绍
    引言: 随着微服务架构的流行,越来越多的企业开始采用微服务来构建他们的应用程序。然而,由于微服务的分布式特性,往往会面临性能
  • 使用Go语言进行代码优化的介绍
    在日常开发中,我们经常需要优化代码,以提高程序的性能和效率。Go语言作为一门高效的编程语言,提供了许多优化技巧和工具来帮助我们
  • 本站所有内容来源于互联网或用户自行发布,本站仅提供信息存储空间服务,不拥有版权,不承担法律责任。如有侵犯您的权益,请您联系站长处理!
  • Copyright © 2017-2022 F11.CN All Rights Reserved. F11站长开发者网 版权所有 | 苏ICP备2022031554号-1 | 51LA统计