mirror of
				https://git.anonymousland.org/anonymousland/synapse.git
				synced 2025-11-03 22:04:02 -05:00 
			
		
		
		
	
		
			
				
	
	
		
			42 lines
		
	
	
	
		
			1.3 KiB
		
	
	
	
		
			Python
		
	
	
	
	
	
			
		
		
	
	
			42 lines
		
	
	
	
		
			1.3 KiB
		
	
	
	
		
			Python
		
	
	
	
	
	
# -*- coding: utf-8 -*-
 | 
						|
# Copyright 2015 OpenMarket Ltd
 | 
						|
#
 | 
						|
# Licensed under the Apache License, Version 2.0 (the "License");
 | 
						|
# you may not use this file except in compliance with the License.
 | 
						|
# You may obtain a copy of the License at
 | 
						|
#
 | 
						|
#     http://www.apache.org/licenses/LICENSE-2.0
 | 
						|
#
 | 
						|
# Unless required by applicable law or agreed to in writing, software
 | 
						|
# distributed under the License is distributed on an "AS IS" BASIS,
 | 
						|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 | 
						|
# See the License for the specific language governing permissions and
 | 
						|
# limitations under the License.
 | 
						|
 | 
						|
from synapse.storage import prepare_database
 | 
						|
 | 
						|
import types
 | 
						|
 | 
						|
 | 
						|
class MariaEngine(object):
 | 
						|
    def __init__(self, database_module):
 | 
						|
        self.module = database_module
 | 
						|
 | 
						|
    def convert_param_style(self, sql):
 | 
						|
        return sql.replace("?", "%s")
 | 
						|
 | 
						|
    def encode_parameter(self, param):
 | 
						|
        if isinstance(param, types.BufferType):
 | 
						|
            return str(param)
 | 
						|
        return param
 | 
						|
 | 
						|
    def on_new_connection(self, db_conn):
 | 
						|
        pass
 | 
						|
 | 
						|
    def prepare_database(self, db_conn):
 | 
						|
        cur = db_conn.cursor()
 | 
						|
        cur.execute(
 | 
						|
            "ALTER DATABASE CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci"
 | 
						|
        )
 | 
						|
        db_conn.commit()
 | 
						|
        prepare_database(db_conn, self)
 |