在AWS Redshift中通过Python UDF还原SQL Server的varbinary十六进制字符串

你的问题核心在于现有UDF没有正确解析GUID的十六进制结构，也没处理SQL Server转换时的字节序反转规则。我们先拆解SQL Server的转换逻辑，再调整UDF实现匹配结果。

SQL Server的转换规则解析 #

当你用CONVERT(varbinary(8), @OrganisationID, 1)时，SQL Server会对GUID的前8字节做特定的字节序反转：

• GUID格式为xxxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx，取前8字节对应的十六进制部分：910D514A-8706-4BA1
• 对各分组做字节反转：
  • 第一组（4字节）：91 0D 51 4A → 反转成 4A 51 0D 91
  • 第二组（2字节）：87 06 → 反转成 06 87
  • 第三组（2字节）：4B A1 → 反转成 A1 4B
• 拼接后得到最终的十六进制串：4A510D910687A14B

调整后的Redshift Python UDF #

下面的UDF会正确处理GUID的结构和字节序：

create or replace function sqlserver_guid_to_varbinary8(data character varying) returns character varying as $$
def process_guid(guid_str):
    # 去掉GUID中的连字符，转为纯十六进制字符串
    clean_guid = guid_str.replace('-', '')
    # 取前16个字符（对应8字节）
    first_8bytes_hex = clean_guid[:16]
    
    # 按SQL Server规则拆分并反转字节
    # 第一组：前8个字符（4字节），每2个字符为一组，反转顺序
    group1 = first_8bytes_hex[:8]
    reversed_group1 = ''.join([group1[i:i+2] for i in range(6, -1, -2)])
    # 第二组：接下来4个字符（2字节），反转分组
    group2 = first_8bytes_hex[8:12]
    reversed_group2 = group2[2:] + group2[:2]
    # 第三组：最后4个字符（2字节），反转分组
    group3 = first_8bytes_hex[12:16]
    reversed_group3 = group3[2:] + group3[:2]
    
    # 拼接所有反转后的分组
    return reversed_group1 + reversed_group2 + reversed_group3

return process_guid(data)
$$ language plpythonu stable;

测试验证 #

执行查询：

select sqlserver_guid_to_varbinary8('910D514A-8706-4BA1-9327-FE92EF4165E3');

会返回4A510D910687A14B，和SQL Server的转换结果完全匹配。

关键说明 #

• 我们没有直接对字符串做编码转换，而是解析GUID的十六进制内容，因为原GUID本身就是十六进制表示的UUID。
• 严格遵循SQL Server在style 1下的字节反转规则，确保输出结果一致。

内容的提问来源于stack exchange，提问作者fez